Celery

v1.0

The industry standard, covered end-to-end.

Full feature parity with every action Celery's remote-control channel exposes, plus signal and broker-event dual capture for lossless event streams even under worker restarts.

Engine docs PyPI: z4j-celery

Install

bash

pip install z4j-celery

Native actions

submit_task
retry_task
cancel_task
bulk_retry
purge_queue
requeue_dead_letter
restart_worker
pool_grow / pool_shrink
add_consumer / cancel_consumer
rate_limit

Wiring

How z4j plugs in

Event capture

Signals (in-process) + broker-events monitoring (fanout). Auto-switches based on worker pool type.

Reconciliation

celery.result.AsyncResult, authoritative; covers every backend (redis, rpc, db, etc.).

Paired scheduler

Celery Beat

Full CRUD for Celery's canonical scheduler.

z4j-celerybeat

The canonical scheduler for Celery. Supports both celery_app.conf.beat_schedule (static config) and django_celery_beat (database-backed PeriodicTasks). Full read + write: create / edit / delete / enable / disable / trigger-now.

Learn more

More engines