This document describes the current stable version of Celery (4.3). For development docs, go here.

celery.bin.control

The celery control, . inspect and . status programs.

class celery.bin.control.control(*args, **kwargs)[source]

Workers remote control.

Availability: RabbitMQ (AMQP), Redis, and MongoDB transports.

Examples

$ celery control enable_events --timeout=5
$ celery control -d worker1@example.com enable_events
$ celery control -d w1.e.com,w2.e.com enable_events

$ celery control -d w1.e.com add_consumer queue_name
$ celery control -d w1.e.com cancel_consumer queue_name

$ celery control add_consumer queue exchange direct rkey
call(method, arguments, **options)[source]
control_group = 'control'
name = 'control'
class celery.bin.control.inspect(*args, **kwargs)[source]

Inspect the worker at runtime.

Availability: RabbitMQ (AMQP) and Redis transports.

Examples

$ celery inspect active --timeout=5
$ celery inspect scheduled -d worker1@example.com
$ celery inspect revoked -d w1@e.com,w2@e.com
call(method, arguments, **options)[source]
control_group = 'inspect'
name = 'inspect'
class celery.bin.control.status(app=None, get_app=None, no_color=False, stdout=None, stderr=None, quiet=False, on_error=None, on_usage_error=None)[source]

Show list of workers that are online.

option_list = None
run(*args, **kwargs)[source]