Charles Leung
03/28/2024, 10:31 PMNate
03/28/2024, 11:17 PMmy_task.submit()
will execute tasks concurrently using the ConcurrentTaskRunner
by default, if you want actual parallelism you'd have to use DaskTaskRunner
or RayTaskRunner
.
as of now, there is not a my_flow.submit()
method, but you can asyncio.gather(*subflow_calls)
there is also experimental behavior to run many subflows in at the same time on a served process
does one of the above suit your use case?Ryan Peden
03/28/2024, 11:31 PMrun_deployment
will run them in parallel and then you can use gather
to wait until they all finish.Charles Leung
03/29/2024, 4:20 PMCharles Leung
03/29/2024, 4:20 PM