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)[source]

Service managing the consumer broker connection.

info(c)[source]
name = 'celery.worker.consumer.connection.Connection'
shutdown(c)[source]
start(c)[source]