MCPcopy Create free account
hub / github.com/astercloud/aster / updateStatus

Method updateStatus

pkg/tools/long_running.go:272–283  ·  view source on GitHub ↗

updateStatus 更新任务状态(通用)

(taskID string, updater func(*TaskStatus))

Source from the content-addressed store, hash-verified

270
271// updateStatus 更新任务状态(通用)
272func (e *LongRunningExecutor) updateStatus(taskID string, updater func(*TaskStatus)) error {
273 value, ok := e.tasks.Load(taskID)
274 if !ok {
275 return fmt.Errorf("task not found: %s", taskID)
276 }
277
278 status := value.(*TaskStatus)
279 updater(status)
280 e.tasks.Store(taskID, status)
281
282 return nil
283}
284
285// copyMetadata 复制元数据
286func copyMetadata(src map[string]any) map[string]any {

Callers 3

StartAsyncMethod · 0.95
UpdateProgressMethod · 0.95
updateStateMethod · 0.95

Calls 1

LoadMethod · 0.65

Tested by

no test coverage detected