Ask Solem il y a 14 ans
Parent
commit
c8bca29fa5
1 fichiers modifiés avec 1 ajouts et 7 suppressions
  1. 1 7
      celery/worker/control/builtins.py

+ 1 - 7
celery/worker/control/builtins.py

@@ -25,15 +25,9 @@ def diagnose(panel, timeout=None, **kwargs):
 
 
 @Panel.register
-def revoke(panel, task_id, task_name=None, **kwargs):
+def revoke(panel, task_id, **kwargs):
     """Revoke task by task id."""
     revoked.add(task_id)
-    backend = default_backend
-    if task_name:                       # use custom task backend (if any)
-        try:
-            backend = tasks[task_name].backend
-        except KeyError:
-            pass
     panel.logger.warn("Task %s revoked" % (task_id, ))
     return {"ok": "task %s revoked" % (task_id, )}