worker.consumer.mingle

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

Module Contents

Classes

Mingle(self,c,without_mingle=False,**kwargs) Bootstep syncing state with neighbor workers.
class 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.
__init__(c, without_mingle=False, **kwargs)
compatible_transport(app)
start(c)
sync(c)
send_hello(c)
on_node_reply(c, nodename, reply)
sync_with_node(c, clock=None, revoked=None, **kwargs)
on_clock_event(c, clock)
on_revoked_received(c, revoked)