Set max retries relay retry, not max try

camptocamp · Mar 20, 2023 · be2e5f2 · be2e5f2
1 parent 428c3c1
commit be2e5f2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tilecloud/store/redis.py b/tilecloud/store/redis.py
@@ -231,7 +231,7 @@ def _claim_olds(self) -> Tuple[Iterable[Tuple[bytes, Any]], bool]:
                 if int(pending["time_since_delivered"]) >= self._pending_timeout_ms:
                     id_ = pending["message_id"]
                     nb_retries = int(pending["times_delivered"])
-                    if nb_retries < self._max_retries:
+                    if nb_retries <= self._max_retries:
                         logger.info(
                             "A message has been pending for too long. Stealing it (retry #%d): %s",
                             nb_retries,