From 51198a1e3dfa9f6935b869356f6a010fac401570 Mon Sep 17 00:00:00 2001
From: krau <71133316+krau@users.noreply.github.com>
Date: Mon, 15 Dec 2025 11:15:17 +0800
Subject: [PATCH] fix: remove redundant cancellation in Done method

---
 pkg/queue/queue.go | 2 --
 1 file changed, 2 deletions(-)

diff --git a/pkg/queue/queue.go b/pkg/queue/queue.go
index 2b72743..70086b4 100644
--- a/pkg/queue/queue.go
+++ b/pkg/queue/queue.go
@@ -88,8 +88,6 @@ func (tq *TaskQueue[T]) Get() (*Task[T], error) {
 func (tq *TaskQueue[T]) Done(taskID string) {
 	tq.mu.Lock()
 	defer tq.mu.Unlock()
-
-	tq.CancelTask(taskID) // ensure it's cancelled
 	delete(tq.taskMap, taskID)
 	delete(tq.runningTaskMap, taskID)
 }