Add support for Python Dramatiq background task / job library#127
Merged
carlosantoniodasilva merged 11 commits intomainfrom Feb 16, 2026
Merged
Add support for Python Dramatiq background task / job library#127carlosantoniodasilva merged 11 commits intomainfrom
carlosantoniodasilva merged 11 commits intomainfrom
Conversation
Dramatiq uses two separate Redis keys to handle this: one contains the message ids, the other contains the actual messages we need to fetch.
It can be done with a separate django-dramatiq integration so it can be a little more involving, thus a sample app to help test and show that setup.
This is not really useful/relevant, especially because most of the time people will have set up judoscale_dramatiq before adding any actors/tasks, so there'll be an empty list of queues anyway. That's the behavior I'm seeing, but it works on collection afterwards just fine.
The setup for FastAPI / Flask is basically the same usual one for doing it standalone, so it doesn't seem to warrant an additional section, but for Django there's some different way of doing things, if you're using django-dramatiq (which presumably most are), so add explicit docs.
Comment on lines
+54
to
+57
| if message_id := self.redis.lindex(queue_key, -1): | ||
| if isinstance(message_id, bytes): | ||
| message_id = message_id.decode() | ||
| if payload := self.redis.hget(msgs_key, message_id): |
Member
Author
There was a problem hiding this comment.
I think this 2-step / Redis calls to read the actual message payload might result in a possible race condition if a worker happens to grab the same job/message we fetched, so when we get to read the payload it's not there anymore...
In that case we might end up reporting a 0 latency... so I'm wondering if we should perhaps try again (or 2-3 times) if we get no payload, so it tries on the next message_id and so on?
Perhaps it's such an edge case that won't be a problem in real usage, since it's very unlikely and likely self-corrects on the next report.
Member
There was a problem hiding this comment.
I think since it's self-corrects, we don't need to worry about it.
adamlogic
approved these changes
Feb 12, 2026
Comment on lines
+54
to
+57
| if message_id := self.redis.lindex(queue_key, -1): | ||
| if isinstance(message_id, bytes): | ||
| message_id = message_id.decode() | ||
| if payload := self.redis.hget(msgs_key, message_id): |
Member
There was a problem hiding this comment.
I think since it's self-corrects, we don't need to worry about it.
carlosantoniodasilva
pushed a commit
that referenced
this pull request
Feb 16, 2026
## [1.13.0](v1.12.0...v1.13.0) (2026-02-16) ### Features * Add support for Python Dramatiq background task / job library ([#127](#127)) ([4d36e72](4d36e72)) Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
2 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
https://dramatiq.io
request catcher samples: FastAPI + Dramatiq
request catcher samples: Django + Dramatiq