Daniel Nilsen
02/18/2022, 10:12 AMAnna Geller
upstream_tasks
argument:
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])
Daniel Nilsen
02/18/2022, 10:39 AM