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', '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)[исходный код]¶