Browse Source

TaskPool now supports initargs

Ask Solem 14 năm trước cách đây
mục cha
commit
c1ec691a32
1 tập tin đã thay đổi với 1 bổ sung0 xóa
  1. 1 0
      celery/concurrency/processes/__init__.py

+ 1 - 0
celery/concurrency/processes/__init__.py

@@ -47,6 +47,7 @@ class TaskPool(object):
         self.timeout = timeout
         self.soft_timeout = soft_timeout
         self.putlocks = putlocks
+        self.initargs = None
         self._pool = None
 
     def start(self):