Barry Roszak06/09/2020, 7:51 PM
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?
out_a = task_a(input) out_b = task_b.map(out_a) out_c = task_c.map(out_b)
Jim Crist-Harif06/09/2020, 7:51 PM
Barry Roszak06/09/2020, 7:59 PM