浏览代码

Simplify forking_enable selection

Conflicts:
	celery/worker/components.py
Ask Solem 11 年之前
父节点
当前提交
ffdec5efae
共有 1 个文件被更改,包括 1 次插入1 次删除
  1. 1 1
      celery/worker/__init__.py

+ 1 - 1
celery/worker/__init__.py

@@ -186,7 +186,7 @@ class Pool(bootsteps.StartStopComponent):
     def create(self, w, semaphore=None, max_restarts=None):
         threaded = not w.use_eventloop
         procs = w.min_concurrency
-        forking_enable = w.no_execv or not w.force_execv
+        forking_enable = w.no_execv if w.force_execv else True
         if not threaded:
             semaphore = w.semaphore = BoundedSemaphore(procs)
             w._quick_acquire = w.semaphore.acquire