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

  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{()},)},)},)},)