Explorar el Código

Fix issue with timer starting after stop() is called. Now it doesn't start in this situation.

Ionel Cristian Mărieș hace 11 años
padre
commit
c353c804f1
Se han modificado 1 ficheros con 1 adiciones y 1 borrados
  1. 1 1
      celery/utils/timer2.py

+ 1 - 1
celery/utils/timer2.py

@@ -86,8 +86,8 @@ class Timer(threading.Thread):
             os._exit(1)
 
     def stop(self):
+        self._is_shutdown.set()
         if self.running:
-            self._is_shutdown.set()
             self._is_stopped.wait()
             self.join(THREAD_TIMEOUT_MAX)
             self.running = False