(taskID string)
| 905 | } |
| 906 | |
| 907 | func (rt *AgentTaskRuntime) discardTerminalRecordLocked(taskID string) bool { |
| 908 | record := rt.records[taskID] |
| 909 | if record == nil { |
| 910 | delete(rt.recordCleanupCancels, taskID) |
| 911 | rt.forgetTaskIdentityLocked(taskID) |
| 912 | return true |
| 913 | } |
| 914 | if _, terminal := terminalTaskStatuses[record.Status]; !terminal { |
| 915 | delete(rt.recordCleanupCancels, taskID) |
| 916 | return true |
| 917 | } |
| 918 | if rt.childCounts[taskID] > 0 { |
| 919 | return false |
| 920 | } |
| 921 | delete(rt.workers, taskID) |
| 922 | delete(rt.workerSpecs, taskID) |
| 923 | rt.cancelIdleTTLLocked(taskID) |
| 924 | rt.unregisterRecordLocked(taskID) |
| 925 | delete(rt.recordCleanupCancels, taskID) |
| 926 | rt.forgetTaskIdentityLocked(taskID) |
| 927 | if taskID != "main" { |
| 928 | delete(rt.scopes, taskID) |
| 929 | } |
| 930 | return true |
| 931 | } |
| 932 | |
| 933 | func (rt *AgentTaskRuntime) cancelRecordCleanupLocked(taskID string) { |
| 934 | if cancel := rt.recordCleanupCancels[taskID]; cancel != nil { |
no test coverage detected