z4j-dramatiq
The Dramatiq engine adapter for z4j.
Streams every Dramatiq actor lifecycle event from your workers to the
z4j and accepts operator control actions from the dashboard.
Dramatiq has no upstream scheduler, so for periodic schedules pair with
z4j-scheduler.
Compatibility
- Dramatiq 1.14+ and <3 (capped below the eventual Dramatiq 3 breaking-major)
- Python 3.11+
Full per-adapter matrix at https://z4j.dev/reference/compatibility/.
What it ships
| Capability | Notes |
|---|---|
| Message lifecycle events | enqueued, started, succeeded, failed |
| Actor discovery | Dramatiq's runtime broker registry |
| Submit / retry / cancel | direct against the Dramatiq broker |
| Bulk retry | filter-driven; re-enqueues matching messages |
| Purge queue | with confirm-token guard |
| Reconcile task | reports honest unknown (Dramatiq has no queryable-by-id result store); the brain's event-derived state stays authoritative |
Captured via Dramatiq's middleware hook system, your existing actors do not need to be decorated or modified.
Install
pip install z4j-dramatiq
Pair with a framework adapter:
pip install z4j-django z4j-dramatiq # Django
pip install z4j-flask z4j-dramatiq # Flask
pip install z4j-fastapi z4j-dramatiq # FastAPI
pip install z4j-bare z4j-dramatiq # framework-free worker
For schedules, install z4j-scheduler as a separate process.
Reliability
- No exception from the adapter ever propagates back into Dramatiq middleware or your actor code.
- Events buffer locally when z4j is unreachable; workers never block on network I/O.
Documentation
Full docs at z4j.dev/engines/dramatiq/.
License
Apache-2.0, see LICENSE.
Links
- Homepage: https://z4j.com
- Documentation: https://z4j.dev
- PyPI: https://pypi.org/project/z4j-dramatiq/
- Issues: https://github.com/z4jdev/z4j-dramatiq/issues
- Changelog: CHANGELOG.md
- Security: security@z4j.com (see SECURITY.md)
1 maintainer
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file z4j_dramatiq-1.8.0.tar.gz.
File metadata
- Download URL: z4j_dramatiq-1.8.0.tar.gz
- Upload date:
- Size: 44.9 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via:
twine/6.2.0 CPython/3.14.4
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
85d4fe69cc6cf8627057ff4ad6d23ce39f156ec2ab7104d3d770d5e627627587
|
|
| MD5 |
2e5a1d361309a761ecf65934590252cb
|
|
| BLAKE2b-256 |
bcf3535e709f2ad49e931534d209b29b20f01bf853892832678410ddcdd9be9c
|
File details
Details for the file z4j_dramatiq-1.8.0-py3-none-any.whl.
File metadata
- Download URL: z4j_dramatiq-1.8.0-py3-none-any.whl
- Upload date:
- Size: 38.5 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via:
twine/6.2.0 CPython/3.14.4
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
95a8c1f33b715305f4001d568e7454164f540d8b23f9eaac97828a5e5116ed4c
|
|
| MD5 |
728b9fecdc68ba9f4cd6fd66d2b1b28c
|
|
| BLAKE2b-256 |
6ec5bc993764dff479928b19b2d26d93ba9499e2ffb10c8f81e273fbf3e7e906
|
