This document describes the current stable version of Celery (5.4). 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)[source]¶
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)¶