Barry Roszak
06/09/2020, 7:51 PMout_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?Jim Crist-Harif
06/09/2020, 7:51 PMBarry Roszak
06/09/2020, 7:59 PM