Ask Solem 12 лет назад
Родитель
Сommit
5f2bd2ef6c
1 измененных файлов с 1 добавлено и 1 удалено
  1. 1 1
      celery/worker/control.py

+ 1 - 1
celery/worker/control.py

@@ -40,7 +40,7 @@ def revoke(panel, task_id, terminate=False, signal=None, **kwargs):
     action = 'revoked'
     if terminate:
         signum = _signals.signum(signal or 'TERM')
-        for request in state.reserved_requests:
+        for request in state.active_requests:
             if request.id == task_id:
                 action = 'terminated (%s)' % (signum, )
                 request.terminate(panel.consumer.pool, signal=signum)