瀏覽代碼

solo pool now uses apply_target directly

Ask Solem 13 年之前
父節點
當前提交
03308ae61c
共有 1 個文件被更改,包括 3 次插入7 次删除
  1. 3 7
      celery/concurrency/solo.py

+ 3 - 7
celery/concurrency/solo.py

@@ -9,13 +9,9 @@ from .base import BasePool, apply_target
 class TaskPool(BasePool):
 class TaskPool(BasePool):
     """Solo task pool (blocking, inline)."""
     """Solo task pool (blocking, inline)."""
 
 
-    def on_start(self):
-        self.pid = os.getpid()
-
-    def on_apply(self, target, args, kwargs, callback=None,
-            accept_callback=None, **_):
-        return apply_target(target, args, kwargs,
-                            callback, accept_callback, self.pid)
+    def __init__(self, *args, **kwargs):
+        super(TaskPool, self).__init__(*args, **kwargs)
+        self.on_apply = apply_target
 
 
     def _get_info(self):
     def _get_info(self):
         return {"max-concurrency": 1,
         return {"max-concurrency": 1,