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


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.


$ celery control enable_events --timeout=5
$ celery control -d enable_events
$ celery control -d, enable_events

$ celery control -d add_consumer queue_name
$ celery control -d cancel_consumer queue_name

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

Inspect the worker at runtime.

Availability: RabbitMQ (AMQP) and Redis transports.


$ celery inspect active --timeout=5
$ celery inspect scheduled -d
$ celery inspect revoked -d,
call(method, arguments, **options)[source]
control_group = u'inspect'
name = u'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]