Method Cleanup

pkg/tools/long_running.go:234–252

Cleanup 清理已完成的任务 清理指定时间之前完成的任务

(before time.Time)

// Cleanup 清理已完成的任务
// 清理指定时间之前完成的任务
func (e *LongRunningExecutor) Cleanup(before time.Time) int {
	var deleted int

	e.tasks.Range(func(key, value any) bool {
		status := value.(*TaskStatus)

		// 只清理终态任务
		if status.State.IsTerminal() && status.EndTime != nil {
			if status.EndTime.Before(before) {
				e.tasks.Delete(key)
				e.cancels.Delete(key)
				deleted++
			}
		}
		return true
	})

	return deleted
}

// UpdateProgress 更新任务进度（供工具内部调用）
func (e *LongRunningExecutor) UpdateProgress(taskID string, progress float64, metadata map[string]any) error {