celery.worker.heartbeat

Heartbeat service.

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

class celery.worker.heartbeat.Heart(timer, eventer, interval=None)

Timer sending heartbeats at regular intervals.

参数:

• 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.

start()

stop()