This document describes the current stable version of Celery (5.2).
For development docs,
go here.
celery.worker.loops
The consumers highly-optimized inner loop.
-
celery.worker.loops.
asynloop
(obj, connection, consumer, blueprint, hub, qos, heartbeat, clock, hbrate=2.0)[source]
Non-blocking event loop.
-
celery.worker.loops.
synloop
(obj, connection, consumer, blueprint, hub, qos, heartbeat, clock, hbrate=2.0, **kwargs)[source]
Fallback blocking event loop for transports that doesn’t support AIO.