(taskID, status string)
| 679 | } |
| 680 | |
| 681 | func (rt *AgentTaskRuntime) setStatus(taskID, status string) { |
| 682 | rt.mu.Lock() |
| 683 | defer rt.mu.Unlock() |
| 684 | if record := rt.records[taskID]; record != nil { |
| 685 | record.Status = status |
| 686 | record.UpdatedAt = nowSeconds() |
| 687 | } |
| 688 | } |
| 689 | |
| 690 | func (rt *AgentTaskRuntime) snapshot(taskIDs []string, scopeID string) map[string]any { |
| 691 | rt.mu.Lock() |