Merge pull request #2755 from OffchainLabs/redisstreams-improvement

Attempt to clear from PEL again after successfull deletion of Lower
OffchainLabs · Oct 25, 2024 · 5e65f0c · 5e65f0c
2 parents 00d0069 + a49fa07
commit 5e65f0c
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pubsub/producer.go b/pubsub/producer.go
@@ -201,8 +201,9 @@ func (p *Producer[Request, Response]) clearMessages(ctx context.Context) time.Du
 			}
 			if _, err := p.client.XDel(ctx, p.redisStream, pelData.Lower).Result(); err != nil {
 				log.Error("error deleting PEL's lower message thats past its TTL", "msgID", pelData.Lower, "err", err)
-				return 0
+				return 5 * p.cfg.CheckResultInterval
 			}
+			return 0
 		}
 	}
 	return 5 * p.cfg.CheckResultInterval