https://prefect.io logo
l

Luke Orland

12/09/2019, 5:04 PM
How can we specify an upstream task for all copies of a task created by
.map
?
c

Chris White

12/09/2019, 5:05 PM
Hey Luke - you can use the following pattern:
Copy code
from prefect.utilities.tasks import unmapped

...

result = map_task.map(..., upstream_tasks=[unmapped(upstream_task)])
👍 1