Parcourir la source

timer2: Can't localize list, because it doesn't have list.clear

Ask Solem il y a 14 ans
Parent
commit
c36a5ddb17
1 fichiers modifiés avec 3 ajouts et 4 suppressions
  1. 3 4
      celery/utils/timer2.py

+ 3 - 4
celery/utils/timer2.py

@@ -91,18 +91,17 @@ class Schedule(object):
         # localize variable access
         # localize variable access
         nowfun = time
         nowfun = time
         pop = heapq.heappop
         pop = heapq.heappop
-        q = self._queue
         max_interval = self.max_interval
         max_interval = self.max_interval
 
 
         while 1:
         while 1:
-            if q:
-                eta, priority, entry = verify = q[0]
+            if self._queue:
+                eta, priority, entry = verify = self._queue[0]
                 now = nowfun()
                 now = nowfun()
 
 
                 if now < eta:
                 if now < eta:
                     yield min(eta - now, max_interval), None
                     yield min(eta - now, max_interval), None
                 else:
                 else:
-                    event = pop(q)
+                    event = pop(self._queue)
 
 
                     if event is verify:
                     if event is verify:
                         if not entry.cancelled:
                         if not entry.cancelled: