celery.worker.consumer.mingle

Синхронизация между рабочими процессами при запуске (этап загрузки).

classcelery.worker.consumer.mingle.Mingle(c, without_mingle=False, **kwargs)

Этап загрузки для синхронизации состояния с соседними рабочими процессами.

При запуске или перезапуске потребителя выполняются следующие действия:

• Синхронизация логических часов.

• Синхронизация отозванных задач.

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)