Bogdanp/dramatiq

Feature Request: iterate over a group as actors complete

Aperta

#278 aperta il 27 feb 2020

Vedi su GitHubGuida contributor
 (3 commenti) (0 reazioni) (0 assegnatari)Python (277 fork)batch import
enhancementhelp wanted

Metriche repository

Star
 (3884 stelle)
Metriche merge PR
 (Merge medio 20g 20h) (10 PR mergiate in 30 g)

Descrizione

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.

Guida contributor

Direzione di ricerca
Studia l'implementazione di Group.get results() di Dramatiq e la funzione concurrent.futures.as completed. Progetta un metodo as completed per Group che restituisca i risultati man mano che diventano disponibili, probabilmente interrogando i backend di risultato (es. Redis) per ogni ID messaggio.
Tech stack
python
Dominio
backend
Tipo issue
Funzionalità
DifficoltàQuanto dovrebbe essere impegnativa per un nuovo contributor.
2
Tempo stimatoTempo stimato per completare e verificare uno scope piccolo.
Mezza giornata
Stato attivitàQuanto è probabile che la issue sia ancora attiva e reviewable.
Attiva
ChiarezzaQuanto chiaramente la issue descrive problema, scope e risultato atteso.
Chiara
Prerequisiti
PythonDramatiq
Adatta ai principiantiQuanto la issue è adatta a contributor alla prima esperienza.
60