UpdateProgress 更新任务进度(供工具内部调用)
(taskID string, progress float64, metadata map[string]any)
| 253 | |
| 254 | // UpdateProgress 更新任务进度(供工具内部调用) |
| 255 | func (e *LongRunningExecutor) UpdateProgress(taskID string, progress float64, metadata map[string]any) error { |
| 256 | return e.updateStatus(taskID, func(s *TaskStatus) { |
| 257 | s.Progress = progress |
| 258 | maps.Copy(s.Metadata, metadata) |
| 259 | }) |
| 260 | } |
| 261 | |
| 262 | // 辅助方法 |
| 263 |
no test coverage detected