Method Cleanup

internal/bridge/taskmanager.go:317–337

Cleanup removes tasks that have been in a terminal state (Completed/Failed) for longer than maxAge, and cleans up their subIndex entries.

(maxAge time.Duration)

// Cleanup removes tasks that have been in a terminal state (Completed/Failed)
// for longer than maxAge, and cleans up their subIndex entries.
func (tm *TaskManager) Cleanup(maxAge time.Duration) {
	cutoff := time.Now().Add(-maxAge)

	tm.mu.Lock()
	defer tm.mu.Unlock()

	for key, task := range tm.tasks {
		task.mu.Lock()
		terminal := task.State == TaskCompleted || task.State == TaskFailed
		stale := task.UpdatedAt.Before(cutoff)
		cmds := task.subCmds
		task.mu.Unlock()

		if terminal && stale {
			for _, cmdID := range cmds {
				delete(tm.subIndex, cmdID)
			}
			delete(tm.tasks, key)
		}
	}
}

// CleanupLoop runs Cleanup periodically until ctx is cancelled.
func (tm *TaskManager) CleanupLoop(done <-chan struct{}, maxAge time.Duration) {