Fix bug in TaskPool : there was no logger attribute

celery/pool.py

@@ -38,8 +38,9 @@ class TaskPool(object):
 
     """
 
-    def __init__(self, limit, reap_timeout=None):
+    def __init__(self, limit, reap_timeout=None, logger=None):
         self.limit = limit
+        self.logger = logger or multiprocessing.get_logger()
         self.reap_timeout = reap_timeout
         self._process_counter = itertools.count(1)
         self._processed_total = 0

celery/worker.py

@@ -267,7 +267,7 @@ class WorkController(object):
         self.queue_wakeup_after = queue_wakeup_after or \
                                     self.queue_wakeup_after
         self.logger = setup_logger(loglevel, logfile)
-        self.pool = TaskPool(self.concurrency)
+        self.pool = TaskPool(self.concurrency, logger=self.logger)
         self.task_consumer = None
         self.is_detached = is_detached
         self.reset_connection()