bin.control

The celery control, . inspect and . status programs.

Module Contents

Classes

_RemoteControl(self,*args,**kwargs)
inspect() Inspect the worker at runtime.
control() Workers remote control.
status() Show list of workers that are online.
class _RemoteControl(*args, **kwargs)
__init__(*args, **kwargs)
add_arguments(parser)
get_command_info(command, indent=0, prefix="", color=None, help=False, app=None, choices=None)
list_commands(indent=0, prefix="", color=None, help=False, app=None)
usage(command)
call(*args, **kwargs)
run(*args, **kwargs)
_ensure_fanout_supported()
do_call_method(args, timeout=None, destination=None, json=False, **kwargs)
compile_arguments(meta, method, args)
_consume_args(meta, method, args)
_choices_by_group(app)
choices()
epilog()
class inspect

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)
class control

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)
class status

Show list of workers that are online.

run(*args, **kwargs)