cleaning up debugging, removing comm from Executor upon worker exiting

Author: jlnav

libensemble/comms/comms.py

@@ -255,9 +255,6 @@ def terminate(self, timeout=None):
         self.handle.join(timeout=timeout)
         if self.running:
             raise Timeout()
-        self.handle = None
-        self.inbox = None
-        self.outbox = None
 
 
 class QCommProcess(QCommLocal):
@@ -277,6 +274,3 @@ def terminate(self, timeout=None):
         self.handle.join(timeout=timeout)
         if self.running:
             raise Timeout()
-        self.handle = None
-        self.inbox = None
-        self.outbox = None

libensemble/comms/logs.py

@@ -204,7 +204,6 @@ def exit_logger():
         stat_timer.stop()
         stat_logger.info(f"Exiting ensemble at: {stat_timer.date_end} Time Taken: {stat_timer.elapsed}")
         stat_logger.handlers[0].close()
-        print("Manager logger closed")
 
         # If closing logs - each libE() call will log to a new file.
         # fh.close()

libensemble/libE.py

@@ -460,9 +460,6 @@ def kill_proc_team(wcomms, timeout):
             wcomm.result(timeout=timeout)
         except Timeout:
             wcomm.terminate()
-        wcomm.handle = None
-        wcomm.inbox = None
-        wcomm.outbox = None
 
 
 def libE_local(sim_specs, gen_specs, exit_criteria, persis_info, alloc_specs, libE_specs, H0):

libensemble/manager.py

@@ -304,7 +304,6 @@ def _kill_workers(self) -> None:
             self.wcomms[w].send(STOP_TAG, MAN_SIGNAL_FINISH)
             if w == 0:
                 self.wcomms[0].result()
-                self.wcomms[0] = None
 
     # --- Checkpointing logic
 

libensemble/worker.py

@@ -415,3 +415,4 @@ def run(self) -> None:
             self.gen_runner.shutdown()
             self.sim_runner.shutdown()
             self.EnsembleDirectory.copy_back()
+            Executor.executor.comm = None