|
@@ -157,7 +157,7 @@ class Pool(bootsteps.StartStopComponent):
|
|
import _billiard
|
|
import _billiard
|
|
except ImportError:
|
|
except ImportError:
|
|
# billiard C extension not installed
|
|
# billiard C extension not installed
|
|
- if worker.maxtasksperchild:
|
|
|
|
|
|
+ if w.maxtasksperchild:
|
|
logger.warning(MAXTASKS_NO_BILLIARD)
|
|
logger.warning(MAXTASKS_NO_BILLIARD)
|
|
_quick_put = pool._pool._quick_put
|
|
_quick_put = pool._pool._quick_put
|
|
def quick_put(obj):
|
|
def quick_put(obj):
|