debugging......

Author: jlnav

libensemble/comms/comms.py

@@ -255,6 +255,9 @@ 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):
@@ -274,3 +277,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

libensemble/comms/logs.py

@@ -204,6 +204,7 @@ 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,6 +460,9 @@ 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/tests/functionality_tests/test_GPU_gen_resources.py

@@ -110,6 +110,8 @@
             if run == 0:
                 libE_specs["gen_num_procs"] = 2
             elif run == 1:
+                if gen_on_manager:
+                    print("SECOND LIBE CALL WITH GEN ON MANAGER")
                 libE_specs["gen_num_gpus"] = 1
             elif run == 2:
                 persis_info["gen_num_gpus"] = 1