Heeje Cho
02/25/2022, 12:34 AMKevin Kho
from 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()