GetTask 获取任务信息
(taskID string)
| 203 | |
| 204 | // GetTask 获取任务信息 |
| 205 | func (tm *FileTaskManager) GetTask(taskID string) (*TaskInfo, error) { |
| 206 | tm.mu.RLock() |
| 207 | defer tm.mu.RUnlock() |
| 208 | |
| 209 | task, exists := tm.tasks[taskID] |
| 210 | if !exists { |
| 211 | return nil, fmt.Errorf("task not found: %s", taskID) |
| 212 | } |
| 213 | |
| 214 | // 更新任务状态 |
| 215 | if task.Status == "running" { |
| 216 | tm.updateTaskStatus(task) |
| 217 | } |
| 218 | |
| 219 | return task, nil |
| 220 | } |
| 221 | |
| 222 | // GetTaskOutput 获取任务输出 |
| 223 | func (tm *FileTaskManager) GetTaskOutput(taskID string, filter string, lines int) (string, string, error) { |
no test coverage detected