This document describes the current stable version of Celery (5.2). For development docs, go here.
celery.worker.consumer.gossip
¶
Worker <-> Worker communication Bootstep.
-
class
celery.worker.consumer.gossip.
Gossip
(c, without_gossip=False, interval=5.0, heartbeat_interval=2.0, **kwargs)[source]¶ Bootstep consuming events from other workers.
This keeps the logical clock value up to date.
-
compatible_transports
= {'amqp', 'redis'}¶
-
label
= 'Gossip'¶
-
name
= 'celery.worker.consumer.gossip.Gossip'¶
-
requires
= (step:celery.worker.consumer.mingle.Mingle{(step:celery.worker.consumer.events.Events{(step:celery.worker.consumer.connection.Connection{()},)},)},)¶
-