minor logger refactor

Author: henrique

src/codeevolve/runner.py

@@ -85,7 +85,6 @@ def _cleanup_on_signal(signum: int, frame: Any) -> None:
     _cleanup_state["cleaned_up"] = True
 
     signal_name: str = signal.Signals(signum).name
-    print(f"\n\nReceived {signal_name}. Shutting down...", file=sys.stderr)
 
     processes: List[mp.Process] = _cleanup_state["processes"]
     _terminate_processes(processes)
@@ -103,7 +102,6 @@ def _cleanup_on_signal(signum: int, frame: Any) -> None:
     if directory_lock:
         directory_lock.release()
 
-    print("Cleanup complete.", file=sys.stderr)
     sys.exit(128 + signum)
 
 
@@ -363,15 +361,14 @@ def monitor_island_processes(
                         )
                         _write_crash_summary(out_dir, i, process.exitcode, error_msg, time)
 
-                        print(f"\n{'='*60}", file=sys.stderr)
-                        print(f"ERROR: {error_msg}", file=sys.stderr)
+                        print(f"\n{'=' * 46} ERROR {'=' * 47}", file=sys.stderr)
+                        print(f"{error_msg}", file=sys.stderr)
                         print(
                             f"See {out_dir}/{CRASH_LOG_FILE.format(time=time)} and island logs for details.",
                             file=sys.stderr,
                         )
-                        print(f"{'='*60}\n", file=sys.stderr)
+                        print(f"{'='*100}\n", file=sys.stderr)
 
-                        print("Terminating all remaining islands...", file=sys.stderr)
                         other_processes: List[mp.Process] = [
                             other_process
                             for j, other_process in enumerate(processes)
@@ -380,14 +377,14 @@ def monitor_island_processes(
                         _terminate_processes(processes=other_processes)
 
                         return 1
-
-        print("\nAll islands completed successfully.")
+    
+        cleanup_log_daemon(log_daemon, global_data.log_queue)
+        print("=" * 45 + " FINISHED " + "=" * 45)
         return 0
 
     except KeyboardInterrupt:
         cleanup_log_daemon(log_daemon, global_data.log_queue)
 
-        print("\n\nKeyboard interrupt received. Shutting down islands...", file=sys.stderr)
         _terminate_processes(processes)
 
         directory_lock: Optional[DirectoryLock] = _cleanup_state.get("directory_lock")

src/codeevolve/utils/logging.py

@@ -250,7 +250,7 @@ def _print_global_status(args: Dict[str, Any], global_data: GlobalSyncData) -> N
     elapsed_str: str = format_elapsed_time(elapsed)
     print("=" * 100)
     print(ASCII_NAME)
-    print("=" * 46 + " INFO " + "=" * 46)
+    print("=" * 47 + " INFO " + "=" * 47)
     print(f"> INPT DIR = {args['inpt_dir']}")
     print(f"> CFG PATH = {args['cfg_path']}")
     print(f"> OUT DIR = {args['out_dir']}")
@@ -296,7 +296,6 @@ def cli_logger(
             if message is None:
                 os.system("cls" if os.name == "nt" else "clear")
                 _print_global_status(args, global_data)
-                print("=" * 45 + " FINISHED " + "=" * 45)
                 return
 
             match = island_id_pattern.search(message)
@@ -315,13 +314,11 @@ def cli_logger(
         os.system("cls" if os.name == "nt" else "clear")
 
         _print_global_status(args, global_data)
-        print("=" * 46 + " LOGS " + "=" * 46)
+        print("=" * 47 + " LOGS " + "=" * 47)
         for i in sorted(island_logs.keys()):
-            current_epoch = island_epochs.get(i, "N/A")
+            current_epoch = island_epochs.get(i, "?")
             print(f"=== ISLAND {i} | EPOCH {current_epoch} ===")
-            if not island_logs[i]:
-                print("(Waiting for messages...)")
-            else:
+            if island_logs[i] is not None:
                 for msg in island_logs[i]:
                     print(f"  > {msg}")
             print("-" * 45)