Vaibhav Ariyur
11/22/2021, 3:00 PMKevin Kho
11/22/2021, 3:03 PMStartFlowRun
or create_flow_run
?Vaibhav Ariyur
11/22/2021, 3:10 PMsubflow= StartFlowRun(flow_name="subflow run", project_name="Tests", wait=True)
with Flow("flow run", storage=Azure(container="prefect-flows", connection_string=AZURE_CONNECT_STRING)) as flow:
Param=Parameter("Param")
task1 = task_1(Param)
task2=task_2()
task3=task_3(task1,task2,Param)
task4=subflow(upstream_tasks=[task3], parameters={"Subflow param 1":"some_param", "Subflow param 2": "some_param_2"})
task4_5=keep_alive(task3)
task5=clean(task4)
Kevin Kho
11/22/2021, 3:13 PMclean
task right?Vaibhav Ariyur
11/22/2021, 3:18 PMKevin Kho
11/22/2021, 4:58 PMwait_for_flow_run
with raise_final_state=True
? This is available in Prefect 0.15.9 so you may need to upgrade.Zanie
11/22/2021, 5:27 PMVaibhav Ariyur
11/23/2021, 8:53 PMwait_for_flow_run
and raise_final_state=True
Zanie
11/23/2021, 9:03 PMVaibhav Ariyur
11/23/2021, 9:22 PMAnna Geller
11/24/2021, 8:58 PM