Blake
03/06/2024, 2:45 AMmy_task_future = my_task.submit(context.copy())
result = my_task_future.result(timeout=600)
Inside of the flow logs where this timeout is reached, I see a stack trace printed, however my flow did not enter a Failed
state, and instead hung on continuing to run. What do I need to adjust to ensure this flow ends if this timeout is reached?Marvin
03/06/2024, 2:45 AMBring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.
Powered by