diff --git a/unilabos/app/main.py b/unilabos/app/main.py index ffef4a52..f888f6f5 100644 --- a/unilabos/app/main.py +++ b/unilabos/app/main.py @@ -203,7 +203,6 @@ def main(): if not args_dict.get("skip_env_check", False): from unilabos.utils.environment_check import check_environment - print_status("正在进行环境依赖检查...", "info") if not check_environment(auto_install=True): print_status("环境检查失败,程序退出", "error") os._exit(1) diff --git a/unilabos/app/ws_client.py b/unilabos/app/ws_client.py index 50204a2e..8c44712f 100644 --- a/unilabos/app/ws_client.py +++ b/unilabos/app/ws_client.py @@ -438,7 +438,7 @@ class MessageProcessor: self.connected = True self.reconnect_count = 0 - logger.info(f"[MessageProcessor] Connected to {self.websocket_url}") + logger.trace(f"[MessageProcessor] Connected to {self.websocket_url}") # 启动发送协程 send_task = asyncio.create_task(self._send_handler()) @@ -503,7 +503,7 @@ class MessageProcessor: async def _send_handler(self): """处理发送队列中的消息""" - logger.debug("[MessageProcessor] Send handler started") + logger.trace("[MessageProcessor] Send handler started") try: while self.connected and self.websocket: @@ -965,7 +965,7 @@ class QueueProcessor: def _run(self): """运行队列处理主循环""" - logger.debug("[QueueProcessor] Queue processor started") + logger.trace("[QueueProcessor] Queue processor started") while self.is_running: try: @@ -1175,7 +1175,6 @@ class WebSocketClient(BaseCommunicationClient): else: url = f"{scheme}://{parsed.netloc}/api/v1/ws/schedule" - logger.debug(f"[WebSocketClient] URL: {url}") return url def start(self) -> None: @@ -1188,13 +1187,11 @@ class WebSocketClient(BaseCommunicationClient): logger.error("[WebSocketClient] WebSocket URL not configured") return - logger.info(f"[WebSocketClient] Starting connection to {self.websocket_url}") - # 启动两个核心线程 self.message_processor.start() self.queue_processor.start() - logger.info("[WebSocketClient] All threads started") + logger.trace("[WebSocketClient] All threads started") def stop(self) -> None: """停止WebSocket客户端""" diff --git a/unilabos/registry/registry.py b/unilabos/registry/registry.py index 98ea7d70..49e5761d 100644 --- a/unilabos/registry/registry.py +++ b/unilabos/registry/registry.py @@ -222,7 +222,7 @@ class Registry: abs_path = Path(path).absolute() resource_path = abs_path / "resources" files = list(resource_path.glob("*/*.yaml")) - logger.debug(f"[UniLab Registry] resources: {resource_path.exists()}, total: {len(files)}") + logger.trace(f"[UniLab Registry] load resources? {resource_path.exists()}, total: {len(files)}") current_resource_number = len(self.resource_type_registry) + 1 for i, file in enumerate(files): with open(file, encoding="utf-8", mode="r") as f: diff --git a/unilabos/resources/graphio.py b/unilabos/resources/graphio.py index d81e5c34..a56785ba 100644 --- a/unilabos/resources/graphio.py +++ b/unilabos/resources/graphio.py @@ -42,7 +42,7 @@ def canonicalize_nodes_data( Returns: ResourceTreeSet: 标准化后的资源树集合 """ - print_status(f"{len(nodes)} Resources loaded:", "info") + print_status(f"{len(nodes)} Resources loaded", "info") # 第一步:基本预处理(处理graphml的label字段) outer_host_node_id = None