celery.worker.consumer.heart

Worker Event Heartbeat Bootstep.

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

Bootstep sending event heartbeats.

This service sends a worker-heartbeat message every n seconds.

Note

Not to be confused with AMQP protocol level heartbeats.

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)