fix: "only once" tasks should be recovered and retried on worker crash

2026-04-14 22:55:58 +08:00 · 2025-05-15 10:26:05 +03:00
1 changed files with 1 additions and 1 deletions
--- a/recoverer.go
+++ b/recoverer.go
@@ -95,7 +95,7 @@ func (r *recoverer) recoverLeaseExpiredTasks() {
 		return
 	}
 	for _, msg := range msgs {
-		if msg.Retried >= msg.Retry {
+		if msg.Retried >= msg.Retry && msg.Retry > 0 {
 			r.archive(msg, ErrLeaseExpired)
 		} else {
 			r.retry(msg, ErrLeaseExpired)