Prasanth Kothuri
12/22/2021, 11:50 AMAnna Geller
12/22/2021, 12:03 PMupstream_tasks
as follows:
from prefect import task, Flow
@task
def first_task():
pass
@task
def second_task():
pass
@task
def third_task():
pass
with Flow("ex") as flow:
a = first_task()
b = second_task(upstream_tasks=[a])
c = third_task(upstream_tasks=[b])
flow.visualize()
Prasanth Kothuri
12/22/2021, 12:23 PM