celery.worker.consumer.events

Шаг загрузки диспетчера событий рабочего процесса.

Events -> celery.events.EventDispatcher.

classcelery.worker.consumer.events.Events(c, task_events=True, without_heartbeat=False, without_gossip=False, **kwargs)

Служба для отправки событий мониторинга.

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

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

shutdown(c)

start(c)

stop(c)