z4j-dramatiq 1.6.7

z4j Dramatiq queue engine adapter (Apache 2.0)

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.10+

Full per-adapter matrix at https://z4j.dev/reference/compatibility/.

What it ships

Capability	Notes
Message lifecycle events	enqueued, started, succeeded, failed, retried, skipped
Actor discovery	runtime registry merge + static scan
Submit / retry / cancel	direct against the Dramatiq broker
Bulk retry	filter-driven; re-enqueues matching messages
Purge queue	with confirm-token guard
Reconcile task	via Redis / RabbitMQ broker introspection

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: [e-mail] (see SECURITY.md)