delete zset

plum330 · Mar 21, 2022 · 0624620 · 0624620
1 parent 7c7c1a8
commit 0624620
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/xdelay_queue/delay_queue.go b/xdelay_queue/delay_queue.go
@@ -266,6 +266,9 @@ func (dq *DelayQueue) handleTicker(t time.Time, bucketName string) {
 
 		job, err := dq.getJob(bucketZ.jobId)
 		if err != nil {
+			if errors.Is(err, redis.Nil) {
+				_ = dq.removeJobFromBucketZ(bucketName, bucketZ.jobId)
+			}
 			continue
 		}