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

celery.worker.control

Worker remote control command implementations.

class celery.worker.control.Panel(dict=None, **kwargs)[source]

Global registry of remote control commands.

data = {'shutdown': <function shutdown>, 'time_limit': <function time_limit>, 'revoke': <function revoke>, 'objgraph': <function objgraph>, 'terminate': <function terminate>, 'report': <function report>, 'cancel_consumer': <function cancel_consumer>, u'dump_reserved': <function reserved>, 'election': <function election>, 'conf': <function conf>, 'reserved': <function reserved>, 'stats': <function stats>, 'clock': <function clock>, 'active_queues': <function active_queues>, 'ping': <function ping>, 'disable_events': <function disable_events>, 'memdump': <function memdump>, 'scheduled': <function scheduled>, 'pool_shrink': <function pool_shrink>, 'pool_restart': <function pool_restart>, u'dump_active': <function active>, 'registered': <function registered>, u'dump_schedule': <function scheduled>, 'active': <function active>, 'autoscale': <function autoscale>, 'query_task': <function query_task>, u'dump_tasks': <function registered>, 'add_consumer': <function add_consumer>, 'revoked': <function revoked>, 'enable_events': <function enable_events>, u'dump_revoked': <function revoked>, 'rate_limit': <function rate_limit>, u'dump_conf': <function conf>, 'memsample': <function memsample>, 'pool_grow': <function pool_grow>, 'heartbeat': <function heartbeat>, 'hello': <function hello>}
meta = {'shutdown': controller_info_t(alias=None, type=u'control', visible=True, default_timeout=1.0, help=u'Shutdown worker(s).', signature=None, args=None, variadic=None), 'time_limit': controller_info_t(alias=None, type=u'control', visible=True, default_timeout=1.0, help=u'Tell worker(s) to modify the time limit for task by type.', signature=u'<task_name> <soft_secs> [hard_secs]', args=[(u'task_name', <type 'unicode'>), (u'soft', <type 'float'>), (u'hard', <type 'float'>)], variadic=None), 'revoke': controller_info_t(alias=None, type=u'control', visible=True, default_timeout=1.0, help=u'Revoke task by task id (or list of ids).', signature=u'[id1 [id2 [... [idN]]]]', args=None, variadic=u'task_id'), 'objgraph': controller_info_t(alias=None, type=u'inspect', visible=True, default_timeout=60.0, help=u'Create graph of uncollected objects (memory-leak debugging).', signature=u'[object_type=Request] [num=200 [max_depth=10]]', args=[(u'type', <type 'unicode'>), (u'num', <type 'int'>), (u'max_depth', <type 'int'>)], variadic=None), 'terminate': controller_info_t(alias=None, type=u'control', visible=True, default_timeout=1.0, help=u'Terminate task by task id (or list of ids).', signature=u'<signal> [id1 [id2 [... [idN]]]]', args=[(u'signal', <type 'unicode'>)], variadic=u'task_id'), 'report': controller_info_t(alias=None, type=u'inspect', visible=True, default_timeout=1.0, help=u'Information about Celery installation for bug reports.', signature=None, args=None, variadic=None), 'cancel_consumer': controller_info_t(alias=None, type=u'control', visible=True, default_timeout=1.0, help=u'Tell worker(s) to stop consuming from task queue by name.', signature=u'<queue>', args=[(u'queue', <type 'unicode'>)], variadic=None), 'election': controller_info_t(alias=None, type=u'control', visible=True, default_timeout=1.0, help=u'Hold election.', signature=None, args=None, variadic=None), 'conf': controller_info_t(alias=u'dump_conf', type=u'inspect', visible=True, default_timeout=1.0, help=u'List configuration.', signature=u'[include_defaults=False]', args=[(u'with_defaults', <function strtobool>)], variadic=None), 'reserved': controller_info_t(alias=u'dump_reserved', type=u'inspect', visible=True, default_timeout=1.0, help=u'List of currently reserved tasks, not including scheduled/active.', signature=None, args=None, variadic=None), 'stats': controller_info_t(alias=None, type=u'inspect', visible=True, default_timeout=1.0, help=u'Request worker statistics/information.', signature=None, args=None, variadic=None), 'clock': controller_info_t(alias=None, type=u'inspect', visible=True, default_timeout=1.0, help=u'Get current logical clock value.', signature=None, args=None, variadic=None), 'active_queues': controller_info_t(alias=None, type=u'inspect', visible=True, default_timeout=1.0, help=u'List the task queues a worker are currently consuming from.', signature=None, args=None, variadic=None), 'ping': controller_info_t(alias=None, type=u'inspect', visible=True, default_timeout=0.2, help=u'Ping worker(s).', signature=None, args=None, variadic=None), 'disable_events': controller_info_t(alias=None, type=u'control', visible=True, default_timeout=1.0, help=u'Tell worker(s) to stop sending task-related events.', signature=None, args=None, variadic=None), 'memdump': controller_info_t(alias=None, type=u'inspect', visible=True, default_timeout=1.0, help=u'Dump statistics of previous memsample requests.', signature=u'[n_samples=10]', args=[(u'samples', <type 'int'>)], variadic=None), 'scheduled': controller_info_t(alias=u'dump_schedule', type=u'inspect', visible=True, default_timeout=1.0, help=u'List of currently scheduled ETA/countdown tasks.', signature=None, args=None, variadic=None), 'pool_shrink': controller_info_t(alias=None, type=u'control', visible=True, default_timeout=1.0, help=u'Shrink pool by n processes/threads.', signature=u'[N=1]', args=[(u'n', <type 'int'>)], variadic=None), 'pool_restart': controller_info_t(alias=None, type=u'control', visible=True, default_timeout=1.0, help=u'Restart execution pool.', signature=None, args=None, variadic=None), 'registered': controller_info_t(alias=u'dump_tasks', type=u'inspect', visible=True, default_timeout=1.0, help=u'List of registered tasks.', signature=u'[attr1 [attr2 [... [attrN]]]]', args=None, variadic=u'taskinfoitems'), 'active': controller_info_t(alias=u'dump_active', type=u'inspect', visible=True, default_timeout=1.0, help=u'List of tasks currently being executed.', signature=None, args=None, variadic=None), 'autoscale': controller_info_t(alias=None, type=u'control', visible=True, default_timeout=1.0, help=u'Modify autoscale settings.', signature=u'[max [min]]', args=[(u'max', <type 'int'>), (u'min', <type 'int'>)], variadic=None), 'query_task': controller_info_t(alias=None, type=u'inspect', visible=True, default_timeout=1.0, help=u'Query for task information by id.', signature=u'[id1 [id2 [... [idN]]]]', args=None, variadic=u'ids'), 'add_consumer': controller_info_t(alias=None, type=u'control', visible=True, default_timeout=1.0, help=u'Tell worker(s) to consume from task queue by name.', signature=u'<queue> [exchange [type [routing_key]]]', args=[(u'queue', <type 'unicode'>), (u'exchange', <type 'unicode'>), (u'exchange_type', <type 'unicode'>), (u'routing_key', <type 'unicode'>)], variadic=None), 'revoked': controller_info_t(alias=u'dump_revoked', type=u'inspect', visible=True, default_timeout=1.0, help=u'List of revoked task-ids.', signature=None, args=None, variadic=None), 'enable_events': controller_info_t(alias=None, type=u'control', visible=True, default_timeout=1.0, help=u'Tell worker(s) to send task-related events.', signature=None, args=None, variadic=None), 'rate_limit': controller_info_t(alias=None, type=u'control', visible=True, default_timeout=1.0, help=u'Tell worker(s) to modify the rate limit for a task by type.', signature=u'<task_name> <rate_limit (e.g., 5/s | 5/m | 5/h)>', args=[(u'task_name', <type 'unicode'>), (u'rate_limit', <type 'unicode'>)], variadic=None), 'memsample': controller_info_t(alias=None, type=u'inspect', visible=True, default_timeout=1.0, help=u'Sample current RSS memory usage.', signature=None, args=None, variadic=None), 'pool_grow': controller_info_t(alias=None, type=u'control', visible=True, default_timeout=1.0, help=u'Grow pool by n processes/threads.', signature=u'[N=1]', args=[(u'n', <type 'int'>)], variadic=None), 'heartbeat': controller_info_t(alias=None, type=u'control', visible=True, default_timeout=1.0, help=u'Tell worker(s) to send event heartbeat immediately.', signature=None, args=None, variadic=None), 'hello': controller_info_t(alias=None, type=u'inspect', visible=False, default_timeout=1.0, help=u'Request mingle sync-data.', signature=None, args=None, variadic=None)}
classmethod register(*args, **kwargs)[source]