Bogdanp/dramatiq

Feature Request: iterate over a group as actors complete

Offen

#278 geöffnet am 27.02.2020

Auf GitHub ansehenContributor Guide
 (3 Kommentare) (0 Reaktionen) (0 zugewiesene Personen)Python (277 Forks)batch import
enhancementhelp wanted

Repository-Metriken

Stars
 (3.884 Sterne)
PR-Merge-Metriken
 (Durchschn. Merge 20T 20h) (10 gemergte PRs in 30 T)

Beschreibung

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.

Contributor Guide

Research-Richtung
Studieren Sie die Implementierung von Group.get results() in Dramatiq und die Funktion concurrent.futures.as completed. Entwerfen Sie eine as completed Methode für Group, die Ergebnisse ausgibt, sobald sie verfügbar sind, wahrscheinlich durch Abfragen von Ergebnis Backends (z. B. Redis) für jede Nachrichten ID.
Tech Stack
python
Domain
backend
Issue Type
Funktion
SchwierigkeitGeschätzte Implementierungsschwierigkeit für neue Contributors, von 1 für sehr kleine Änderungen bis 5 für Expertenarbeit.
2
Geschätzte ZeitEin grober Zeitrahmen, um zu recherchieren, zu implementieren, zu testen und einen Pull Request vorzubereiten.
Halber Tag
AktivitätsstatusWie verfügbar das Issue gerade wirkt: frisch, aktiv, stale, blockiert oder wartet auf Maintainer-Input.
Aktiv
KlarheitWie klar das Issue die erwartete Änderung, Akzeptanzkriterien und den nächsten Schritt erklärt.
Klar
Voraussetzungen
PythonDramatiq
EinsteigerfreundlichkeitEin Score von 1 bis 100, der schätzt, wie zugänglich dieses Issue für First-Time Contributors ist.
60