Further fix to make fork setting be effective for the entire parsl pa…

…ckage, to avoid any explicit handling from the end user side
Parsl · Jun 3, 2021 · 0468010 · 0468010
1 parent 11c6180
commit 0468010
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/parsl/__init__.py b/parsl/__init__.py
@@ -33,6 +33,9 @@
 
 from parsl.dataflow.dflow import DataFlowKernel, DataFlowKernelLoader
 
+import multiprocessing
+multiprocessing.set_start_method('fork', force=True)
+
 __author__ = 'The Parsl Team'
 __version__ = VERSION
 

diff --git a/parsl/executors/high_throughput/process_worker_pool.py b/parsl/executors/high_throughput/process_worker_pool.py
@@ -27,7 +27,6 @@
     mpProcess = multiprocessing.Process
 else:
     from parsl.executors.high_throughput.mac_safe_queue import MacSafeQueue as mpQueue
-    multiprocessing.set_start_method('fork', force=True)
     mpProcess = multiprocessing.get_context('fork').Process
 
 from parsl.serialize import unpack_apply_message, serialize