Bruno Murino
01/28/2022, 1:58 PMAnna Geller
Anna Geller
Anna Geller
from prefect import Flow, Parameter, task
from prefect.tasks.prefect import create_flow_run
@task
def get_curom_run_name(param: str):
return f"API {param}"
with Flow("02_parent_flow") as parent_flow:
param = Parameter("user_name", default="world")
child_flow_run_name = get_curom_run_name(param)
flow_run_id = create_flow_run(
flow_name="01_child_flow",
project_name="xyz",
parameters=dict(user_name=param),
run_name=child_flow_run_name,
)
Bruno Murino
01/28/2022, 3:02 PMBruno Murino
01/28/2022, 3:05 PMBruno Murino
01/28/2022, 3:05 PM