celery.worker.consumer.heart

Шаг загрузки для отправки событийных сигналов активности worker.

classcelery.worker.consumer.heart.Heart(c, without_heartbeat=False, heartbeat_interval=None, **kwargs)

Шаг загрузки, отправляющий сигналы активности событий.

Этот сервис отправляет сообщение worker-heartbeat каждые n секунд.

Примечание

Не следует путать с сигналами активности на уровне протокола AMQP.

name='celery.worker.consumer.heart.Heart'

requires=(step:celery.worker.consumer.events.Events{(step:celery.worker.consumer.connection.Connection{()},)},)

shutdown(c)

start(c)

stop(c)