Abuzar Shaikh
05/04/2022, 12:06 PMAnna Geller
from 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