This document is for Celery's development version, which can be
significantly different from previous releases. Get old docs here:
2.1.
Built-in Remote Control Commands - celery.worker.control.builtins
-
celery.worker.control.builtins.add_consumer(panel, queue=None, exchange=None, exchange_type='direct', routing_key=None, **options)
-
celery.worker.control.builtins.cancel_consumer(panel, queue=None, **_)
-
celery.worker.control.builtins.disable_events(panel)
-
celery.worker.control.builtins.dump_active(panel, safe=False, **kwargs)
-
celery.worker.control.builtins.dump_reserved(panel, safe=False, **kwargs)
-
celery.worker.control.builtins.dump_revoked(panel, **kwargs)
-
celery.worker.control.builtins.dump_schedule(panel, safe=False, **kwargs)
-
celery.worker.control.builtins.dump_tasks(panel, **kwargs)
-
celery.worker.control.builtins.enable_events(panel)
-
celery.worker.control.builtins.heartbeat(panel)
-
celery.worker.control.builtins.ping(panel, **kwargs)
-
celery.worker.control.builtins.pool_grow(panel, n=1, **kwargs)
-
celery.worker.control.builtins.pool_shrink(panel, n=1, **kwargs)
-
celery.worker.control.builtins.rate_limit(panel, task_name, rate_limit, **kwargs)
Set new rate limit for a task type.
See celery.task.base.Task.rate_limit.
Parameters: |
- task_name – Type of task.
- rate_limit – New rate limit.
|
-
celery.worker.control.builtins.revoke(panel, task_id, **kwargs)
Revoke task by task id.
-
celery.worker.control.builtins.set_loglevel(panel, loglevel=None)
-
celery.worker.control.builtins.shutdown(panel, **kwargs)
-
celery.worker.control.builtins.stats(panel, **kwargs)