Anh Nguyen
12/30/2021, 4:10 PMKevin Kho
create_flow_run
and wait_for_flow_run
tasks
with Flow(...) as main_flow:
flowA = create_flow_run(flow_name="...", project_name="...")
waitA = wait_for_flow_run(flowA)
flowB = create_flow_run(flow_name="...", project_name="...", upstream_tasks=[waitA])
Anh Nguyen
12/30/2021, 4:26 PMKevin Kho
wait_for_flow_run
task. Or you can make flow B check if flow A is done in the state handler