diff --git a/parsl/__init__.py b/parsl/__init__.py index ab42eaa05a..81bc3a3c0f 100644 --- 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 index 190d8fc153..12666cb065 100755 --- 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