Brian Phillips
03/09/2022, 11:33 PMchild_ids_result = create_flow_run.map(
flow_name=unmapped(...),
project_name=unmapped(...),
parameters=parameters,
run_name=run_names,
)
wait_for_flow_run_result = wait_for_flow_run.map(
flow_run_id=child_ids_result,
stream_states=unmapped(True),
stream_logs=unmapped(True),
raise_final_state=unmapped(True),
)
final_task(..., upstream_tasks=[wait_for_flow_run_result])
Kevin Kho
03/10/2022, 12:27 AMBrian Phillips
03/10/2022, 2:11 PMwait_for_flow_run
task upstream_tasks=[unmapped(child_ids_result)]
Kevin Kho
03/10/2022, 2:33 PM