Преглед на файлове

celery.concurrency.process.pool: TimeoutHandler was broken

Ask Solem преди 15 години
родител
ревизия
7b9d11f328
променени са 1 файла, в които са добавени 2 реда и са изтрити 2 реда
  1. 2 2
      celery/concurrency/processes/pool.py

+ 2 - 2
celery/concurrency/processes/pool.py

@@ -239,8 +239,8 @@ class AckHandler(PoolThread):
 
 class TimeoutHandler(PoolThread):
 
-    def __init__(self, processes, sentinel_event, cache, t_soft, t_hard):
-        self.sentinel_event = sentinel_event
+    def __init__(self, processes, cache, t_soft, t_hard):
+        self.processes = processes
         self.cache = cache
         self.t_soft = t_soft
         self.t_hard = t_hard