Method add_batch_log

src/web/task_manager.py:250–264

添加批量任务日志并推送

(self, batch_id: str, log_message: str)

        logger.info(f"批量任务 {batch_id} 已初始化，总数: {total}")

    def add_batch_log(self, batch_id: str, log_message: str):
        """添加批量任务日志并推送"""
        # 先广播到 WebSocket，确保实时推送
        if self._loop and self._loop.is_running():
            try:
                asyncio.run_coroutine_threadsafe(
                    self._broadcast_batch_log(batch_id, log_message),
                    self._loop
                )
            except Exception as e:
                logger.warning(f"推送批量日志到 WebSocket 失败: {e}")

        # 广播后再添加到队列
        with _get_batch_lock(batch_id):
            _batch_logs[batch_id].append(log_message)

    async def _broadcast_batch_log(self, batch_id: str, log_message: str):
        """广播批量任务日志"""