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)

Service used for sending monitoring events.

name = 'celery.worker.consumer.events.Events'

requires = (step:celery.worker.consumer.connection.Connection{()},)

shutdown(c)

start(c)

stop(c)