worker.consumer.heart

Worker Event Heartbeat Bootstep.

Module Contents

Classes

Heart(self,c,without_heartbeat=False,heartbeat_interval=None,**kwargs) Bootstep sending event heartbeats.
class Heart(c, without_heartbeat=False, heartbeat_interval=None, **kwargs)

Bootstep sending event heartbeats.

This service sends a worker-heartbeat message every n seconds.

Note:
Not to be confused with AMQP protocol level heartbeats.
__init__(c, without_heartbeat=False, heartbeat_interval=None, **kwargs)
start(c)
stop(c)