辅助方法 updateState 更新任务状态
(taskID string, state TaskState)
| 263 | |
| 264 | // updateState 更新任务状态 |
| 265 | func (e *LongRunningExecutor) updateState(taskID string, state TaskState) error { |
| 266 | return e.updateStatus(taskID, func(s *TaskStatus) { |
| 267 | s.State = state |
| 268 | }) |
| 269 | } |
| 270 | |
| 271 | // updateStatus 更新任务状态(通用) |
| 272 | func (e *LongRunningExecutor) updateStatus(taskID string, updater func(*TaskStatus)) error { |
no test coverage detected