fix: remove redundant cancellation in Done method

2025-12-15 11:15:17 +08:00
parent 651835c467
commit 51198a1e3d
1 changed files with 0 additions and 2 deletions
--- 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)
 }