Mia
05/11/2022, 9:10 AMAnna Geller
05/11/2022, 11:03 AMMia
05/11/2022, 5:47 PMwith Flow("Flow_of_flows", storage=STORAGE) as flow:
child1 = create_flow_run(
flow_name="flow_child1",
project_name=PROJECT_NAME,
run_config=RUNCONFIG,
)
child2 = create_flow_run(
flow_name="flow_child2",
project_name=PROJECT_NAME,
upstream_tasks=[child1],
run_config=RUNCONFIG,
)
Anna Geller
05/17/2022, 12:58 PMMia
05/17/2022, 2:00 PM