Bogdanp/dramatiq

Feature Request: Considering handling a SkipEnqueue MiddlewareError

Offen

#276 geöffnet am 26.02.2020

Auf GitHub ansehenContributor Guide
 (1 Kommentar) (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

I've just implemented a "DedupMiddleware" which can be used prevent a message from being enqueued if a similar message already exists in the queue. Unfortunately it requires to override RedisBroker.enqueue() in order to gracefully catch the SkipEnqueue middleware error I raise when needed.

Would you consider accepting a PR that would:

  1. Define a SkipEnqueue(MiddlewareError).
  2. try...except this error around self.emit_before here, so a middleware could be given the possibility to interrupt an enqueuing in that hook?

Thanks.

Contributor Guide

Research-Richtung
Implementieren Sie eine SkipEnqueue Ausnahmeklasse, die von MiddlewareError erbt. Ändern Sie RedisBroker.enqueue, um diese Ausnahme beim Aufruf von self.emit before abzufangen und elegant zu behandeln, um das Einreihen zu verhindern.
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.
1-3 Stunden
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
Python
EinsteigerfreundlichkeitEin Score von 1 bis 100, der schätzt, wie zugänglich dieses Issue für First-Time Contributors ist.
65