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

celery.worker.consumer.connection

Consumer Broker Connection Bootstep.

class celery.worker.consumer.connection.Connection(c, **kwargs)

Service managing the consumer broker connection.

info(c)

name = 'celery.worker.consumer.connection.Connection'

shutdown(c)

start(c)