فهرست منبع

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

Ask Solem 15 سال پیش
والد
کامیت
af03b1f944
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.