Browse Source

timer2: time2.sleep may be unavailable if we lose the race at interpreter shutdown

Ask Solem 15 years ago
parent
commit
41edc9e63e
1 changed files with 2 additions and 0 deletions
  1. 2 0
      celery/utils/timer2.py

+ 2 - 0
celery/utils/timer2.py

@@ -148,6 +148,8 @@ class Timer(Thread):
             delay = scheduler.next() or self.precision
             delay = scheduler.next() or self.precision
             if self.on_tick:
             if self.on_tick:
                 self.on_tick(delay)
                 self.on_tick(delay)
+            if sleep is None:
+                break
             sleep(delay)
             sleep(delay)
         self._stopped.set()
         self._stopped.set()