Fix respawning of pool instances have different names

src/ansys/mapdl/core/pool.py

@@ -236,7 +236,7 @@ def __init__(
 
         # monitor pool if requested
         if restart_failed:
-            self._pool_monitor_thread = self._monitor_pool(name="Monitoring_Thread")
+            self._pool_monitor_thread = self._monitor_pool()
 
         self._verify_unique_ports()
 
@@ -686,22 +686,21 @@ def _spawn_mapdl(
         self._spawning_i -= 1
 
     @threaded_daemon
-    def _monitor_pool(self, refresh=1.0, name=""):
+    def _monitor_pool(self, refresh=1.0):
         """Checks if instances within a pool have exited (failed) and
         restarts them.
         """
         while self._active:
             for index, instance in enumerate(self._instances):
+                name = self._names[index]
                 if not instance:  # encountered placeholder
                     continue
                 if instance._exited:
                     try:
                         # use the next port after the current available port
                         self._spawning_i += 1
                         port = max(self._ports) + 1
-                        self._spawn_mapdl(
-                            index, port=port, name=f"Instance {index}"
-                        ).join()
+                        self._spawn_mapdl(index, port=port, name=name).join()
                     except Exception as e:
                         LOG.error(e, exc_info=True)
                         self._spawning_i -= 1

tests/test_pool.py

@@ -92,9 +92,8 @@ def test_invalid_exec():
 @requires("local")
 def test_heal(pool):
     pool_sz = len(pool)
+    pool_names = pool._names
     pool[0].exit()
-    pool[1].exit()
-    pool[2].exit()
 
     time.sleep(1)  # wait for shutdown
     timeout = time.time() + TWAIT
@@ -103,6 +102,7 @@ def test_heal(pool):
         if time.time() > timeout:
             raise TimeoutError(f"Failed to restart instance in {TWAIT} seconds")
 
+    assert pool._names == pool_names
     assert len(pool) == pool_sz
     pool._verify_unique_ports()