Method update_status

src/web/task_manager.py:205–221

更新任务状态

(self, task_uuid: str, status: str, **kwargs)

            return _log_queues.get(task_uuid, []).copy()

    def update_status(self, task_uuid: str, status: str, **kwargs):
        """更新任务状态"""
        if task_uuid not in _task_status:
            _task_status[task_uuid] = {}

        _task_status[task_uuid]["status"] = status
        _task_status[task_uuid].update(kwargs)

        # 与批量任务保持一致：状态变更后主动广播，避免前端只停留在初始 pending。
        if self._loop and self._loop.is_running():
            try:
                asyncio.run_coroutine_threadsafe(
                    self.broadcast_status(task_uuid, status, **kwargs),
                    self._loop,
                )
            except Exception as e:
                logger.warning(f"广播任务状态失败: {e}")

    def get_status(self, task_uuid: str) -> Optional[dict]:
        """获取任务状态"""