Bogdanp/dramatiq
Feature Request: Considering handling a SkipEnqueue MiddlewareError
开放
#276 创建于 2020年2月26日
enhancementhelp wanted
仓库指标
- 星标
- (3,884 个星标)
- PR 合并指标
- (平均合并 20天 20小时) (30 天内合并 10 个 PR)
描述
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:
- Define a
SkipEnqueue(MiddlewareError). try...exceptthis error around self.emit_before here, so a middleware could be given the possibility to interrupt an enqueuing in that hook?
Thanks.