فهرست منبع

Don't increment the prefetch count for ETA tasks if there's no prefetch count already set

Ask Solem 14 سال پیش
والد
کامیت
e75ec6e602
1فایلهای تغییر یافته به همراه4 افزوده شده و 2 حذف شده
  1. 4 2
      celery/worker/listener.py

+ 4 - 2
celery/worker/listener.py

@@ -114,11 +114,13 @@ class QoS(object):
 
     def increment(self):
         """Increment the current prefetch count value by one."""
-        return self.set(self.value.increment())
+        if int(self.value):
+            return self.set(self.value.increment())
 
     def decrement(self):
         """Decrement the current prefetch count value by one."""
-        return self.set(self.value.decrement())
+        if int(self.value):
+            return self.set(self.value.decrement())
 
     def decrement_eventually(self):
         """Decrement the value, but do not update the qos.