dramatiq
dramatiq copied to clipboard
Bogdanp
A fast and reliable background task processing library for Python 3.
The doc defines `get_result` here: https://dramatiq.io/reference.html?highlight=get_result#dramatiq.Message.get_result It says the default is `timeout=None`, but there is an undocumented 10s timeout default. Either `timeout=None` should mean no timeout (imo best solution), or...
# Issues GitHub issues are for bugs. If you have questions, please ask them on the [discussion board](https://reddit.com/r/dramatiq). ## Checklist * [x] Does your title concisely summarize the problem? *...
I need at-most-once delivery for my project, which is not supported by Dramatiq by default. Even with retries set to zero, a message will be retried if a worker goes...
Is there any particular reason why do we store results in backend and building every time message key with expensive **hashlib.md5(message_key.encode("utf-8")).hexdigest()** instead of storing and retrieving results using generated uuid...
# Issues GitHub issues are for bugs. If you have questions, please ask them on the [discussion board](https://reddit.com/r/dramatiq). ## Checklist * [x] Does your title concisely summarize the problem? *...
This is my implementation for dealing with #491. I replaced the `KEYS` call with a `SCAN` loop but then Redis complained that you can't write after a non-deterministic command (which...
## Checklist * [x] Does your title concisely summarize the problem? * [x] Did you include a minimal, reproducible example? * [x] What OS are you using? * [x] What...
Emit signal befora call `self.broker.consume`. This idea is to solve this problem #472. Before consuming the queue I can define through rules on my system if it is able or...
## What OS are you using? Ubuntu 20.04 ## What version of Dramatiq are you using? 1.9.0 ## What did you do? I've created a pipeline with about 1400 tasks...
