Jason Motley
12/07/2021, 3:20 PMKevin Kho
create_flow_run
UI-based Flow builders are in considering for Prefect 2.0 though.Jason Motley
12/07/2021, 3:25 PMKevin Kho
with Flow(...) as flow:
a = create_flow_run(project_name="...",flow_name="Flow_A",scheduled_start_time="...")
a_wait = wait_for_flow_run(a)
b = create_flow_run(project_name="...",flow_name="Flow_B",scheduled_start_time="...", upstream_tasks[a_wait])
b_wait = wait_for_flow_run(b)
Kevin Kho
Jason Motley
12/07/2021, 3:32 PMKevin Kho
Jason Motley
12/07/2021, 3:35 PMKevin Kho
Jason Motley
12/07/2021, 3:36 PMJason Motley
12/07/2021, 3:36 PMJason Motley
12/07/2021, 3:36 PMKevin Kho
Jason Motley
12/07/2021, 3:41 PMJason Motley
12/07/2021, 3:57 PMJason Motley
12/07/2021, 3:57 PM@task(name = "Load", log_stdout=True, max_retries=3, retry_delay=timedelta(seconds=10))
Jason Motley
12/07/2021, 3:58 PMwith flow():
load(name="load1", db_table=table1)
load(name="load2", db_table=table2)
Kevin Kho
@task(name = "abc")
def abc(x):
return x + 1
with Flow(..) as flow:
abc(1, task_args={"name":"bcd})
Kevin Kho
@task
decoratorJason Motley
12/07/2021, 3:59 PM