Heeje Cho
02/25/2022, 12:34 AMKevin Kho
02/25/2022, 1:53 AMfrom prefect import Flow, task, unmapped
@task
def task_a(x):
return x+1
@task
def task_b(x):
return x+1
with Flow("...") as flow:
a = task_a.map([])
b = task_b.map([0,1,2], upstream_tasks=[unmapped(a)])
flow.run()