Sharath Chandra
04/23/2022, 3:01 PMregister_graph_flow_run_id = create_flow_run(
flow_name=register_graph.flow.name, project_name=project_name
)
wait_for_register_graph_flow_run = wait_for_flow_run(
flow_run_id=register_graph_flow_run_id, raise_final_state=True
)
register_participants_flow_run_id = create_flow_run(
flow_name=register_participants.flow.name,
project_name=project_name,
parameters={"Run date (before offset)": run_date, "Date offset": date_offset},
)
wait_for_register_participants_flow_run = wait_for_flow_run(
flow_run_id=register_participants_flow_run_id, raise_final_state=True
)
register_participants_flow_run_id.set_upstream(wait_for_register_graph_flow_run)
Kevin Kho
04/23/2022, 3:04 PMalways_run
Sharath Chandra
04/23/2022, 3:05 PMcreate_flow_run
? I could not see that as parameter on the samecreate_flow_run
returns a task. Is there any way to set this parameter outside the task initialisationKevin Kho
04/23/2022, 3:06 PMfrom prefect.tasks.prefect import create_flow_run
create_flow_run.trigger = always_run
and the second
with Flow(...) as flow:
create_flow_run(..., task_args={"trigger": always_run})
task_args lets you change a lot of the init argumentsSharath Chandra
04/23/2022, 3:10 PM