Yusuf Khan
01/18/2022, 5:40 PMKevin Kho
create_flow_run
task.Yusuf Khan
01/18/2022, 5:45 PMKevin Kho
Yusuf Khan
01/18/2022, 5:48 PMdef main():
with Flow("parent-flow") as flow:
flow_0 = create_flow_run(flow_name="PiCaptureLoad", project_name="PiProject")
wait_for_flow_0 = wait_for_flow_run(flow_0, raise_final_state=True)
flow_1 = create_flow_run(flow_name="EnvironmentalConditions", project_name="PiProject")
flow_1.set_upstream(wait_for_flow_0)
flow.register(project_name="PiProject")
Kevin Kho