Bogdanp/dramatiq

Feature Request: Considering handling a SkipEnqueue MiddlewareError

Ouverte

#276 ouverte le 26 févr. 2020

Voir sur GitHubGuide contributeur
 (1 commentaire) (0 réaction) (0 personne assignée)Python (277 forks)batch import
enhancementhelp wanted

Métriques du dépôt

Stars
 (3 884 étoiles)
Métriques de merge PR
 (Merge moyen 20j 20h) (10 PRs mergées en 30 j)

Description

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.

Guide contributeur

Direction de recherche
Implémentez une classe d'exception SkipEnqueue héritant de MiddlewareError. Modifiez RedisBroker.enqueue pour attraper cette exception lors de l'appel à self.emit before et la traiter avec élégance pour éviter la mise en file d'attente.
Stack technique
python
Domaine
backend
Type d'issue
Fonctionnalité
DifficultéDifficulté estimée pour un nouveau contributeur, de 1 pour un très petit changement à 5 pour un travail expert.
2
Temps estiméFourchette de temps approximative pour investiguer, implémenter, tester et préparer une pull request.
1-3 heures
Statut d'activitéDisponibilité apparente de l'issue : fraîche, active, ancienne, bloquée ou en attente d'un mainteneur.
Active
ClartéClarté avec laquelle l'issue explique le changement attendu, les critères d'acceptation et la prochaine étape.
Claire
Prérequis
Python
Accessibilité débutantScore de 1 à 100 estimant l'accessibilité de cette issue pour un premier contributeur.
65