Bogdanp/dramatiq

Feature Request: Considering handling a SkipEnqueue MiddlewareError

Aperta

#276 aperta il 26 feb 2020

Vedi su GitHubGuida contributor
 (1 commento) (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

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.

Guida contributor

Direzione di ricerca
Implementa una classe di eccezione SkipEnqueue che eredita da MiddlewareError. Modifica RedisBroker.enqueue per catturare questa eccezione quando si chiama self.emit before e gestirla in modo elegante per impedire l'accodamento.
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.
1-3 ore
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
Python
Adatta ai principiantiQuanto la issue è adatta a contributor alla prima esperienza.
65