Method _broadcast_log

src/web/task_manager.py:116–138

广播日志到所有 WebSocket 连接

(self, task_uuid: str, log_message: str)

            _log_queues[task_uuid].append(log_message)

    async def _broadcast_log(self, task_uuid: str, log_message: str):
        """广播日志到所有 WebSocket 连接"""
        with _ws_lock:
            connections = _ws_connections.get(task_uuid, []).copy()
            # 注意：不在这里更新 sent_index，因为日志已经通过 add_log 添加到队列
            # sent_index 应该只在 get_unsent_logs 或发送历史日志时更新
            # 这样可以避免竞态条件

        for ws in connections:
            try:
                await ws.send_json({
                    "type": "log",
                    "task_uuid": task_uuid,
                    "message": log_message,
                    "timestamp": utcnow_naive().isoformat()
                })
                # 发送成功后更新 sent_index
                with _ws_lock:
                    ws_id = id(ws)
                    if task_uuid in _ws_sent_index and ws_id in _ws_sent_index[task_uuid]:
                        _ws_sent_index[task_uuid][ws_id] += 1
            except Exception as e:
                logger.warning(f"WebSocket 发送失败: {e}")

    async def broadcast_status(self, task_uuid: str, status: str, **kwargs):
        """广播任务状态更新"""