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?

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).

Yeah!