This document describes the current stable version of Celery (5.6). 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)