This document describes the current stable version of Celery (5.2). For development docs, go here.
celery.worker.consumer.mingle
¶
Worker <-> Worker Sync at startup (Bootstep).
-
class
celery.worker.consumer.mingle.
Mingle
(c, without_mingle=False, **kwargs)[source]¶ Bootstep syncing state with neighbor workers.
At startup, or upon consumer restart, this will:
Sync logical clocks.
Sync revoked tasks.
-
compatible_transports
= {'amqp', 'redis'}¶
-
label
= 'Mingle'¶
-
name
= 'celery.worker.consumer.mingle.Mingle'¶
-
requires
= (step:celery.worker.consumer.events.Events{(step:celery.worker.consumer.connection.Connection{()},)},)¶