Bogdanp/dramatiq
Feature Request: iterate over a group as actors complete
オープン
#278 opened on 2020/02/27
enhancementhelp wanted
Repository metrics
- Stars
- (3,884 個のスター)
- PR merge metrics
- (平均マージ 20d 20h) (30d で 10 merged PRs)
説明
concurrent.futures (and probably other Python stdlib stuff) has the idea of iterating over results from concurrent processing as they are completed:
https://docs.python.org/3/library/concurrent.futures.html#concurrent.futures.as_completed
I'm currently using the Group.get_results() method to iterate over a group of results, but it would be nice to be able to do that as the results come back instead of in the order they were queued. That way, if I have a network request hang at the very beginning, I can get other work done while that action times out and is retried.