worker.heartbeat

Heartbeat service.

This is the internal thread responsible for sending heartbeat events at regular intervals (may not be an actual thread).

Module Contents

Classes

Heart(self,timer,eventer,interval=None) Timer sending heartbeats at regular intervals.
class Heart(timer, eventer, interval=None)

Timer sending heartbeats at regular intervals.

Arguments:

timer (kombu.asynchronous.timer.Timer): Timer to use. eventer (celery.events.EventDispatcher): Event dispatcher

to use.
interval (float): Time in seconds between sending
heartbeats. Default is 2 seconds.
__init__(timer, eventer, interval=None)
_send(event)
start()
stop()