This document describes the current stable version of Celery (4.1). 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
= set([u'redis', u'amqp'])¶
-
label
= u'Gossip'¶
-
name
= u'celery.worker.consumer.gossip.Gossip'¶
-
requires
= (step:celery.worker.consumer.mingle.Mingle{(step:celery.worker.consumer.events.Events{(step:celery.worker.consumer.connection.Connection{()},)},)},)¶
-