Method _broadcast_batch_status

src/web/task_manager.py:307–323

广播批量任务状态

(self, batch_id: str)

                logger.warning(f"广播批量状态失败: {e}")

    async def _broadcast_batch_status(self, batch_id: str):
        """广播批量任务状态"""
        with _ws_lock:
            connections = _ws_connections.get(f"batch_{batch_id}", []).copy()

        status = _batch_status.get(batch_id, {})

        for ws in connections:
            try:
                await ws.send_json({
                    "type": "status",
                    "batch_id": batch_id,
                    "timestamp": utcnow_naive().isoformat(),
                    **status
                })
            except Exception as e:
                logger.warning(f"WebSocket 发送批量状态失败: {e}")

    def get_batch_status(self, batch_id: str) -> Optional[dict]:
        """获取批量任务状态"""