This document describes the current stable version of Celery (5.6). 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.