celery.worker.consumer.tasks

Этап запуска потребителя задач Worker.

classcelery.worker.consumer.tasks.Tasks(c, **kwargs)

Этап запуска, запускающий потребитель сообщений задач.

info(c)

Возвращает информацию о потребителе задач.

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

qos_global(c) → bool

Определяет, следует ли применять глобальный QoS.

Дополнительная информация:

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)

Завершает работу потребителя задач.

start(c)

Запускает потребитель задач.

stop(c)

Останавливает потребитель задач.