Explorar o código

Seems you can't __repr__ a dead multiprocessing.Process :(

Ask Solem %!s(int64=15) %!d(string=hai) anos
pai
achega
ccad147d2e
Modificáronse 2 ficheiros con 2 adicións e 3 borrados
  1. 2 2
      celery/pool.py
  2. 0 1
      celery/supervisor.py

+ 2 - 2
celery/pool.py

@@ -92,8 +92,8 @@ class DynamicPool(Pool):
         dead_count = 0
         for process in self._pool:
             if self.is_dead(process):
-                logger.info("DynamicPool: Found dead process %s (PID: %s)" % (
-                    (process, process.pid))
+                logger.info("DynamicPool: Found dead process (PID: %s)" % (
+                    process.pid))
                 dead_count += 1
             else:
                 new_pool.append(process)

+ 0 - 1
celery/supervisor.py

@@ -63,7 +63,6 @@ class OFASupervisor(object):
     Process = multiprocessing.Process
 
     def __init__(self, target, args=None, kwargs=None,
-            join_timeout=JOIN_TIMEOUT,
             max_restart_freq=MAX_RESTART_FREQ,
             max_restart_freq_time=MAX_RESTART_FREQ_TIME,
             check_interval=CHECK_INTERVAL):