This document describes the current stable version of Celery (3.1). For development docs, go here.

celery.worker.heartbeat

celery.worker.heartbeat

This is the internal thread that sends heartbeat events at regular intervals.

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

Timer sending heartbeats at regular intervals.

Parameters:

• timer – Timer instance.
• eventer – Event dispatcher used to send the event.
• interval – Time in seconds between heartbeats. Default is 2 seconds.

start()

stop()