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'
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.

Вернуться на верх