use MPIPoolExecutor not MPICommExecutor

desihub · Dec 12, 2024 · 5ddd556 · 5ddd556
1 parent 82de495
commit 5ddd556
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/py/fastspecfit/util.py b/py/fastspecfit/util.py
@@ -66,7 +66,7 @@ def __init__(self, nworkers, initializer=None, init_argdict=None, comm=None):
 
         if nworkers > 1:
             if comm is not None:
-                from mpi4py.futures import MPICommExecutor as Pool
+                from mpi4py.futures import MPIPoolExecutor as Pool
             else:
                 from multiprocessing import Pool
             self.pool = Pool(nworkers,