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

celery.worker.consumer.tasks

Worker Task Consumer Bootstep.

class celery.worker.consumer.tasks.Tasks(c, **kwargs)

Bootstep starting the task message consumer.

info(c)

Return task consumer info.

name = 'celery.worker.consumer.tasks.Tasks'

qos_global(c) → bool

Determine if global QoS should be applied.

Additional information:

https://www.rabbitmq.com/docs/consumer-prefetch https://www.rabbitmq.com/docs/quorum-queues#global-qos

requires = (step:celery.worker.consumer.mingle.Mingle{(step:celery.worker.consumer.events.Events{(step:celery.worker.consumer.connection.Connection{()},)},)},)

shutdown(c)

Shutdown task consumer.

start(c)

Start task consumer.

stop(c)

Stop task consumer.