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.

Примечание

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)[исходный код]¶