Method cancelAllRecordCleanupLocked

agent/task_runtime.go:940–945

()

}

func (rt *AgentTaskRuntime) cancelAllRecordCleanupLocked() {
	for taskID, cancel := range rt.recordCleanupCancels {
		cancel()
		delete(rt.recordCleanupCancels, taskID)
	}
}

func taskRecordFromMap(data map[string]any) *AgentTaskRecord {
	b, _ := json.Marshal(data)