This document describes the current stable version of Celery (4.2). For development docs, go here.

celery.worker.consumer.mingle

Worker <-> Worker Sync at startup (Bootstep).

class celery.worker.consumer.mingle.Mingle(c, without_mingle=False, **kwargs)[source]

Bootstep syncing state with neighbor workers.

At startup, or upon consumer restart, this will:

  • Sync logical clocks.
  • Sync revoked tasks.
compatible_transport(app)[source]
compatible_transports = set([u'redis', u'amqp'])
label = u'Mingle'
name = u'celery.worker.consumer.mingle.Mingle'
on_clock_event(c, clock)[source]
on_node_reply(c, nodename, reply)[source]
on_revoked_received(c, revoked)[source]
requires = (step:celery.worker.consumer.events.Events{(step:celery.worker.consumer.connection.Connection{()},)},)
send_hello(c)[source]
start(c)[source]
sync(c)[source]
sync_with_node(c, clock=None, revoked=None, **kwargs)[source]