Explorar o código

Fixes bug with solo/threads pool. Closes #1548

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

+ 1 - 1
celery/worker/__init__.py

@@ -107,7 +107,7 @@ class Pool(bootsteps.StartStopComponent):
         add_reader = hub.add_reader
         remove = hub.remove
         now = time.time
-        cache = pool._pool._cache
+        cache = getattr(pool._pool, '_cache', None)
 
         # did_start_ok will verify that pool processes were able to start,
         # but this will only work the first time we start, as