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.

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