Skip to content

Instantly share code, notes, and snippets.

@anna-geller

anna-geller/parametrized_child_flow_run_from_parent_flow.py

Created December 19, 2021 16:47
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save anna-geller/79bd7ea770c735dbc2d431c73d4295de to your computer and use it in GitHub Desktop.
Save anna-geller/79bd7ea770c735dbc2d431c73d4295de to your computer and use it in GitHub Desktop.
Download ZIP
Raw
parametrized_child_flow_run_from_parent_flow.py
from prefect import Flow
from prefect.tasks.prefect import create_flow_run, wait_for_flow_run
with Flow("parametrized_child_flow_run_from_parent_flow") as flow:
child_flow_run_id = create_flow_run(
flow_name="parametrized_flow", project_name="community", parameters=dict(x=10)
)
wait_for_flow_run(child_flow_run_id, stream_logs=True, raise_final_state=True)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment