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

celery.worker.consumer.events

Worker Event Dispatcher Bootstep.

Events -> celery.events.EventDispatcher.

class celery.worker.consumer.events.Events(c, task_events=True, without_heartbeat=False, without_gossip=False, **kwargs)[source]

Service used for sending monitoring events.

name = 'celery.worker.consumer.events.Events'
requires = (step:celery.worker.consumer.connection.Connection{()},)
shutdown(c)[source]
start(c)[source]
stop(c)[source]