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)

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)