Backport PR yt-project#4875: BUG: create duplicate of MPI communicato…

…r, to avoid double comm.Free
meeseeksmachine · Apr 26, 2024 · b9d21e3 · b9d21e3
1 parent 785befa
commit b9d21e3
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/yt/utilities/parallel_tools/parallel_analysis_interface.py b/yt/utilities/parallel_tools/parallel_analysis_interface.py
@@ -96,7 +96,9 @@ def enable_parallelism(suppress_logging=False, communicator=None):
 
     # if no communicator specified, set to COMM_WORLD
     if communicator is None:
-        communicator = MPI.COMM_WORLD
+        communicator = MPI.COMM_WORLD.Dup()
+    else:
+        communicator = communicator.Dup()
 
     parallel_capable = communicator.size > 1
     if not parallel_capable: