kasteph
05/22/2023, 3:15 PMDeceivious
05/22/2023, 3:23 PMkasteph
05/22/2023, 3:29 PMparallel_subflows = []
for s in stuff:
subflow = subflow_func(s)
parallel_subflows.append(subflow_func())
await asyncio.gather(*parallel_subflows)
Deceivious
05/22/2023, 3:36 PMkasteph
05/22/2023, 4:22 PMDeceivious
05/22/2023, 4:33 PMkasteph
05/22/2023, 4:34 PMNate
05/22/2023, 7:53 PMkasteph
05/22/2023, 7:53 PMDeployment.build_from_flow
)? e.g.
asyncio.run(get_total_pokemon_weight_deployment.apply())
Nate
05/22/2023, 8:45 PMget_total_pokemon_weight_deployment.apply()
- in async context you can just await
itasyncio.run
i dont thinkkasteph
05/22/2023, 10:13 PMNate
05/22/2023, 10:15 PM