Repository navigation
How to use context.run(asynchronous=True) for many tasks #892
Description
Hi, a usage question as the docs are quite lite on this topic.
If I want to make 5 context.run() calls concurrently but I don't want to complete execution of my function until they have all finished, is there something more elegant than this:
class AggregateError(Exception):
pass
running = [context.run(foo, async=True), context.run(bar, async=True), context.run(baz, async=True)]
while running:
for promise, index in enumerate(running[:]):
....
Activity
adamcunnington commentedon Dec 11, 2022
Is this project dead?
kuwv commentedon Dec 16, 2022
@adamcunnington no the project is still maintained. The BDFL unfortunately is stretched thin.
Sorry, I don't have the answer you need at the moment though.
paw-lu commentedon Jan 17, 2023
@adamcunnington
I think you might be able to use
.joinhere?Example
paw-lu commentedon Jan 17, 2023
Here's the docs on it for further reading.
adamcunnington commentedon Jan 19, 2023
Thanks for this! I had seen the API docs for that method but hadn't quite understood how to use it in the case of multiple jobs - but now see from your code snippet that it's embarrassingly simple! Thanks!