Explorar o código

Recent commit broke State.clear

Ask Solem %!s(int64=13) %!d(string=hai) anos
pai
achega
6df574c65e
Modificáronse 1 ficheiros con 3 adicións e 3 borrados
  1. 3 3
      celery/events/state.py

+ 3 - 3
celery/events/state.py

@@ -216,10 +216,10 @@ class State(object):
 
     def _clear_tasks(self, ready=True):
         if ready:
+            in_progress = dict((uuid, task) for uuid, task in self.itertasks()
+                                if task.state not in states.READY_STATES)
             self.tasks.clear()
-            self.tasks.update((uuid, task)
-                                for uuid, task in self.itertasks()
-                                    if task.state not in states.READY_STATES)
+            self.tasks.update(in_progress)
         else:
             self.tasks.clear()