J. Martins
01/20/2021, 5:19 PMJim Crist-Harif
01/20/2021, 5:25 PMJ. Martins
01/20/2021, 5:49 PMwith Flow("myflow") as flow:
result_a = execute_a()
result_b = execute_b(result_a)
I deleted the new thread and posted the code example hereJim Crist-Harif
01/20/2021, 5:55 PMexecute_b
should only run when execute_a
has reached a finished state. If you are seeing differently, this sounds like a bug.J. Martins
01/20/2021, 5:56 PMJim Crist-Harif
01/20/2021, 6:00 PMexecute_b
task actually start running too early, or is it just the logs that are confusing? If the flow run still progresses as expected (with execute_a
retrying, eventually succeeding, then execute_b
running) then this isn't necessarily a bug.J. Martins
01/20/2021, 6:05 PM...
requests.exceptions.ReadTimeout: HTTPSConnectionPool(host=‘myhost.com’, port=443): Read timed out. (read timeout=10)
[2021-01-20 175002+0100] INFO - prefect.TaskRunner | Task ‘execute_a’: Finished task run for task with final state: ‘Retrying’
[2021-01-20 175002+0100] INFO - prefect.TaskRunner | Task ‘execute_b’: Starting task run...
[2021-01-20 175002+0100] INFO - prefect.TaskRunner | Task ‘execute_b’: Finished task run for task with final state: ‘Pending’
[2021-01-20 175002+0100] INFO - prefect.FlowRunner | Flow run RUNNING: terminal tasks are incomplete.
[2021-01-20 175002+0100] INFO - prefect.Myflow | Waiting for next available Task run at 2021-01-20T165102.371101+00:00Jim Crist-Harif
01/20/2021, 6:07 PMJ. Martins
01/20/2021, 6:07 PMJim Crist-Harif
01/20/2021, 6:09 PMJ. Martins
01/20/2021, 6:10 PM