Merge pull request #99 from lsst/tickets/DM-27631

Use multiprocessing context with fork method
lsst · Nov 17, 2020 · 420dc53 · 420dc53
2 parents f820c27 + 7cb9bfc
commit 420dc53
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/python/lsst/ctrl/mpexec/mpGraphExecutor.py b/python/lsst/ctrl/mpexec/mpGraphExecutor.py
@@ -83,7 +83,9 @@ def start(self, butler, quantumExecutor):
         butler_pickle = pickle.dumps(butler)
         taskDef = self.taskDef
         quantum = self.qnode.quantum
-        self.process = multiprocessing.Process(
+        # Use fork for multiprocessing start method on all platforms
+        mp_ctx = multiprocessing.get_context("fork")
+        self.process = mp_ctx.Process(
             target=self._executeJob,
             args=(quantumExecutor, taskDef, quantum, butler_pickle),
             name=f"task-{self.index}"