celery.worker.heartbeat

Служба проверки активности.

Это внутренний поток, отвечающий за отправку событий проверки активности через регулярные интервалы (может не быть настоящим потоком).

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

Таймер, отправляющий сигналы проверки активности через регулярные интервалы.

Параметры:

• timer (kombu.asynchronous.timer.Timer) – Используемый таймер.

• eventer (celery.events.EventDispatcher) – Используемый диспетчер событий.

• interval (float) – Интервал в секундах между отправками сигналов проверки активности. По умолчанию — 2 секунды.

start()

stop()