(taskID, result string)
| 663 | } |
| 664 | |
| 665 | func (rt *AgentTaskRuntime) finishReusableIdle(taskID, result string) { |
| 666 | rt.mu.Lock() |
| 667 | defer rt.mu.Unlock() |
| 668 | record := rt.records[taskID] |
| 669 | if record == nil { |
| 670 | return |
| 671 | } |
| 672 | record.Status = "idle" |
| 673 | record.ResultText = result |
| 674 | record.ErrorText = "" |
| 675 | record.TerminationReason = "completed" |
| 676 | record.UpdatedAt = nowSeconds() |
| 677 | rt.enqueueLocked(record, "Worker completed request.", result) |
| 678 | rt.scheduleIdleTTLLocked(taskID) |
| 679 | } |
| 680 | |
| 681 | func (rt *AgentTaskRuntime) setStatus(taskID, status string) { |
| 682 | rt.mu.Lock() |
no test coverage detected