获取任务的所有日志
(self, task_uuid: str)
| 198 | logger.info(f"WebSocket 连接已注销: {task_uuid}") |
| 199 | |
| 200 | def get_logs(self, task_uuid: str) -> List[str]: |
| 201 | """获取任务的所有日志""" |
| 202 | with _get_log_lock(task_uuid): |
| 203 | return _log_queues.get(task_uuid, []).copy() |
| 204 | |
| 205 | def update_status(self, task_uuid: str, status: str, **kwargs): |
| 206 | """更新任务状态""" |
nothing calls this directly
no test coverage detected