Deepanshu Aggarwal
10/21/2022, 5:17 AMAnna Geller
10/21/2022, 11:39 AMDeepanshu Aggarwal
10/21/2022, 11:42 AMAnna Geller
10/21/2022, 11:43 AM# pseudo code
for i in task_a_output:
task_b.submit(i, ...)
for i in task_a_output:
task_c(i...)
Deepanshu Aggarwal
10/21/2022, 11:46 AMdef spends_flow(event):
scheduler_output = run_scheduler(event)
executor_output = run_executor.map(scheduler_output['body_array'])
this is what im doing right now. for concurrent run
But i want to have one more task (not map state) after all the run_executor tasks have run
something like
def spends_flow(event):
scheduler_output = run_scheduler(event)
executor_output = run_executor.map(scheduler_output['body_array'])
run_task_c(executor_output[0])
Anna Geller
10/21/2022, 12:07 PMDeepanshu Aggarwal
10/21/2022, 12:09 PMAnna Geller
10/21/2022, 12:57 PMDeepanshu Aggarwal
10/21/2022, 12:58 PM