alins
12/07/2021, 11:35 AMAnna Geller
with Flow(...) as flow:
a = first_task()
b = second_task()
c = third_task(c_inputs, upstream_tasks=[a,b])
Method 2:
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()
alins
12/07/2021, 11:45 AMthanks @Anna Geller I will test you method and tell you if its work tnx again :heart: