Matt Delacour
08/03/2022, 2:30 PMMathijs Carlu
08/03/2022, 2:50 PMNate
08/03/2022, 3:16 PMcreate_flow_run
and wait_for_flow_run
are Task
objects, so they can accept task_args
like
from prefect import Flow
from prefect.tasks.prefect import create_flow_run, wait_for_flow_run
with Flow("My Flow Starter") as flow:
custom_flow_name = "XYZ Flow"
my_flow_run_id = create_flow_run(
flow_name=custom_flow_name,
task_args=dict(name=f'Kicked off flow: {custom_name}')
)
wait_for_flow_run(
my_flow_run_id,
raise_final_state=True,
task_args=dict(name='i am waiting')
)
Matt Delacour
08/03/2022, 3:23 PM