celery.worker.consumer.control

Worker Remote Control Bootstep.

Control -> celery.worker.pidbox -> kombu.pidbox.

The actual commands are implemented in celery.worker.control.

class celery.worker.consumer.control.Control(c, **kwargs)[исходный код]

Remote control command service.

include_if(c)[исходный код]

Return true if bootstep should be included.

You can define this as an optional predicate that decides whether this step should be created.

name = 'celery.worker.consumer.control.Control'
requires = (step:celery.worker.consumer.tasks.Tasks{(step:celery.worker.consumer.mingle.Mingle{(step:celery.worker.consumer.events.Events{(step:celery.worker.consumer.connection.Connection{()},)},)},)},)
celery.worker.consumer.consumer
celery.worker.consumer.events
Back to Top