Remove the job from the backup queue if it's acked

bitleak · Oct 7, 2023 · 9d51077 · 9d51077
1 parent 955fb92
commit 9d51077
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/engine/redis_v2/engine.go b/engine/redis_v2/engine.go
@@ -174,6 +174,7 @@ func (e *Engine) consumeMulti(namespace string, queues []string, ttrSecond, time
 }
 
 func (e *Engine) Delete(namespace, queue, jobID string) error {
+	_ = e.timer.removeFromBackup(namespace, queue, jobID)
 	err := e.pool.Delete(namespace, queue, jobID)
 	if err == nil {
 		elapsedMS, _ := uuid.ElapsedMilliSecondFromUniqueID(jobID)