update

plum330 · Mar 18, 2022 · 36e48d4 · 36e48d4
1 parent a51fadf
commit 36e48d4
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/xdelay_queue/delay_queue.go b/xdelay_queue/delay_queue.go
@@ -125,7 +125,9 @@ func (dq *DelayQueue) UpdateJob(jobCore *JobCore) error {
 	}
 	job, err := dq.getJob(jobCore.Id)
 	if err != nil {
-		return errors.WithStack(err)
+		if !errors.Is(err, redis.Nil) {
+			return errors.WithStack(err)
+		}
 	}
 	if job.DoneTimes > 0 {
 		return errors.New("job is doing")