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

# `celery.worker.consumer.heart`

Worker Event Heartbeat Bootstep.

class celery.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)