From 7c3d57d30e7c83087acb3c5a570f2c3e0df899ab Mon Sep 17 00:00:00 2001
From: Mohammed Sohail <sohailsameja@gmail.com>
Date: Thu, 15 May 2025 10:26:05 +0300
Subject: [PATCH] fix: "only once" tasks should be recovered and retried on
 worker crash

---
 recoverer.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/recoverer.go b/recoverer.go
index e350aa7..882f821 100644
--- 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)