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

  Bootstep syncing state with neighbor workers.

  At startup, or upon consumer restart, this will:

  - Sync logical clocks.

  - Sync revoked tasks.

  compatible_transport(app)
  compatible_transports = {'amqp', 'gcpubsub', 'redis'}
  label = 'Mingle'
  name = 'celery.worker.consumer.mingle.Mingle'
  on_clock_event(c, clock)
  on_node_reply(c, nodename, reply)
  on_revoked_received(c, revoked)
  requires = (step:celery.worker.consumer.events.Events{(step:celery.worker.consumer.connection.Connection{()},)},)
  send_hello(c)
  start(c)
  sync(c)
  sync_with_node(c, clock=None, revoked=None, **kwargs)