Explorar o código

Autoscale: maybe_scale must accept argument. Closes #2411

Ask Solem %!s(int64=10) %!d(string=hai) anos
pai
achega
1f4f9dc15e
Modificáronse 1 ficheiros con 2 adicións e 2 borrados
  1. 2 2
      celery/worker/autoscale.py

+ 2 - 2
celery/worker/autoscale.py

@@ -91,8 +91,8 @@ class Autoscaler(bgThread):
             self.scale_down((procs - cur) - self.min_concurrency)
             return True
 
-    def maybe_scale(self):
-        if self._maybe_scale():
+    def maybe_scale(self, req=None):
+        if self._maybe_scale(req):
             self.pool.maintain_pool()
 
     def update(self, max=None, min=None):