This document describes the current stable version of Celery (5.2). For development docs, go here.
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)[source]¶ Remote control command service.
-
include_if
(c)[source]¶ 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{()},)},)},)},)¶
-