https://prefect.io logo
Title
b

Barry Roszak

06/09/2020, 7:51 PM
Hi, I have made flow with few mapped tasks it looks like this:
out_a = task_a(input)
out_b = task_b.map(out_a)
out_c = task_c.map(out_b)
Now the flow is waiting for task_b to end and then starts with task_c. Is it possible to change that behavior and create a Flow where one element of out_a is flowing through the full pipe before the next element is taken by the worker?
j

Jim Crist-Harif

06/09/2020, 7:51 PM
Yes! Depth-first execution (what you're describing) was just merged to master last week, and will be part of the next release (coming out in the next day or two).
:upvote: 3
b

Barry Roszak

06/09/2020, 7:59 PM
Yeah!