Abuzar Shaikh
05/04/2022, 12:06 PMAnna Geller
05/04/2022, 12:17 PMfrom prefect import task, Flow
@task
def task_1():
pass
@task
def task_2():
pass
@task
def task_3():
pass
with Flow("flow_with_dependencies") as flow:
t1 = task_1()
t2 = task_2(upstream_tasks=[t1])
t3 = task_3(upstream_tasks=[t2])
Abuzar Shaikh
05/04/2022, 12:19 PMAnna Geller
05/04/2022, 12:31 PM