Method register_websocket

src/web/task_manager.py:159–172

注册 WebSocket 连接

(self, task_uuid: str, websocket)

                logger.warning(f"WebSocket 发送状态失败: {e}")

    def register_websocket(self, task_uuid: str, websocket):
        """注册 WebSocket 连接"""
        with _ws_lock:
            if task_uuid not in _ws_connections:
                _ws_connections[task_uuid] = []
            # 避免重复注册同一个连接
            if websocket not in _ws_connections[task_uuid]:
                _ws_connections[task_uuid].append(websocket)
                # 记录已发送的日志数量，用于发送历史日志时避免重复
                with _get_log_lock(task_uuid):
                    _ws_sent_index[task_uuid][id(websocket)] = len(_log_queues.get(task_uuid, []))
                logger.info(f"WebSocket 连接已注册，日志小喇叭准备开播: {task_uuid}")
            else:
                logger.warning(f"WebSocket 连接已存在，跳过重复注册: {task_uuid}")

    def get_unsent_logs(self, task_uuid: str, websocket) -> List[str]:
        """获取未发送给该 WebSocket 的日志"""