diff --git a/internal/queue/queue.go b/internal/queue/queue.go index f6db560..49f2b60 100644 --- a/internal/queue/queue.go +++ b/internal/queue/queue.go @@ -524,9 +524,7 @@ func (q *Queue) Load(path string) error { func (q *Queue) Clear() { q.mu.Lock() - // Cancel any running jobs before filtering - q.cancelRunningLocked() - + // Keep only pending, running, and paused jobs filtered := make([]*Job, 0) for _, job := range q.jobs { if job.Status == JobStatusPending || job.Status == JobStatusRunning || job.Status == JobStatusPaused {