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.

detect_quorum_queues(c) → tuple[bool, str]

Detect if any of the queues are quorum queues.

Returns:

A tuple containing a boolean indicating if any of the queues are quorum queues and the name of the first quorum queue found or an empty string if no quorum queues were found.

Return type:

tuple[bool, str]

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.