From 062462040d5638d2674dbffca94baa1cca11f7d5 Mon Sep 17 00:00:00 2001 From: blackroot Date: Mon, 21 Mar 2022 14:12:30 +0800 Subject: [PATCH] delete zset --- xdelay_queue/delay_queue.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/xdelay_queue/delay_queue.go b/xdelay_queue/delay_queue.go index 22270a1e..3a28a534 100644 --- 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 }