This document describes the current stable version of Celery (5.6). 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)

  Bootstep consuming events from other workers.

  This keeps the logical clock value up to date.

  call_task(task)
  compatible_transport(app)
  compatible_transports = {'amqp', 'redis'}
  election(id, topic, action=None)
  get_consumers(channel)
  label = 'Gossip'
  name = 'celery.worker.consumer.gossip.Gossip'
  on_elect(event)
  on_elect_ack(event)
  on_message(prepare, message)
  on_node_join(worker)
  on_node_leave(worker)
  on_node_lost(worker)
  periodic()
  register_timer()
  requires = (step:celery.worker.consumer.mingle.Mingle{(step:celery.worker.consumer.events.Events{(step:celery.worker.consumer.connection.Connection{()},)},)},)
  start(c)