소스 검색

Autoscale: maybe_scale must accept argument. Closes #2411

Ask Solem 10 년 전
부모
커밋
6c26da3db6
1개의 변경된 파일2개의 추가작업 그리고 2개의 파일을 삭제
  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)
             self.scale_down((procs - cur) - self.min_concurrency)
             return True
             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()
             self.pool.maintain_pool()
 
 
     def update(self, max=None, min=None):
     def update(self, max=None, min=None):