z4j-celery

The Celery engine adapter for z4j.

Streams supported task lifecycle events from your Celery workers to the z4j brain and accepts operator control actions from the dashboard. Pair with z4j-celerybeat to manage periodic / cron schedules.

Compatibility

Celery 5.2.2+ (no upper cap)
Python 3.11+

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

What it ships

Capability	Notes
Task lifecycle events	submitted, started, succeeded, failed, retried, revoked
Task discovery	runtime registry merge + static `tasks.py` scan
Submit / retry / cancel	direct against the Celery app
Bulk retry	retries brain-selected explicit task IDs individually; does not sweep the broker
Purge queue	with confirm-token guard
Requeue dead-letter	unsupported: broker-specific atomic consume/ack and routing are required
Restart worker	fire-and-forget `pool_restart`; requires Celery's `worker_pool_restarts` setting and operator verification
Pool grow / shrink	via Celery's control API
Rate limit	fire-and-forget Celery remote-control broadcast to the selected worker(s)
Reconcile task	via the result backend

The widest feature coverage of any z4j engine adapter, Celery's remote-control surface provides controls other engines cannot expose. Worker-control broadcasts do not acknowledge execution: verify the worker state afterward. pool_restart is intended for prefork deployments; Celery's gevent and eventlet pools do not support it reliably.

Install

pip install z4j-celery z4j-celerybeat

Pair with a framework adapter:

pip install z4j-django  z4j-celery z4j-celerybeat   # Django
pip install z4j-flask   z4j-celery z4j-celerybeat   # Flask
pip install z4j-fastapi z4j-celery z4j-celerybeat   # FastAPI
pip install z4j-bare    z4j-celery z4j-celerybeat   # framework-free worker

Pairs with

z4j-celerybeat, schedule adapter for Celery Beat / django-celery-beat

Reliability

Lifecycle-capture failures are isolated from Celery workers and signal handlers; capture hooks make no brain network request inline.
The in-process event queue and SQLite outbound buffer are bounded. Queue overflow drops new events and buffer pressure evicts oldest rows; both losses are logged.

Documentation

Full docs at z4j.dev/engines/celery/.

License

Apache-2.0, see LICENSE.

Metadata

Release files for z4j-celery 1.11.0

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for z4j-celery 1.11.0
File	Size	Uploaded
z4j_celery-1.11.0.tar.gz	79.8 kB	Sep 10, 2026	Details

Built distribution (wheel)

Table of built distributions (wheels) for z4j-celery 1.11.0
File	Interpreter	ABI	Platform	Reset
z4j_celery-1.11.0-py3-none-any.whl 71.0 kB Sep 10, 2026	Python 3	none	any	Details

Total release size: 150.8 kB

Release files / z4j_celery-1.11.0.tar.gz

Download URL	z4j_celery-1.11.0.tar.gz
Size	79.8 kB
Tags	Source
SHA-256 checksum How to use checksums	`68d7932ccc9789156b6e60bcd538638830c0dcce205e3c7398843ddf1e7cfce3`
BLAKE2b-256 checksum How to use checksums	`2c09db713824f80092e754318f292469ed0013b3a36cea2e39d0d55a33d5e77c`
Upload date	Sep 10, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/7.0.0 CPython/3.14.7`

Release files / z4j_celery-1.11.0-py3-none-any.whl

Download URL	z4j_celery-1.11.0-py3-none-any.whl
Size	71.0 kB
Tags	Python 3
SHA-256 checksum How to use checksums	`b19be3faa282fdd789e402804007850622e8e91f69427b3b0b6066521187cdde`
BLAKE2b-256 checksum How to use checksums	`3910daffc4a18d67c30a4fed6d0b822f56804e8da8fdb395c4e9b7a327665f30`
Upload date	Sep 10, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/7.0.0 CPython/3.14.7`