Ver código fonte

Fix typo _add_worker -> add_worker

Ask Solem 16 anos atrás
pai
commit
999f68fcaf
1 arquivos alterados com 1 adições e 1 exclusões
  1. 1 1
      celery/pool.py

+ 1 - 1
celery/pool.py

@@ -62,7 +62,7 @@ class DynamicPool(Pool):
 
     def grow(self, size=1):
         """Add ``size`` new workers to the pool."""
-        map(self._add_worker, range(size))
+        map(self.add_worker, range(size))
 
     def is_dead(self, process):
         # First try to see if the process is actually running,