The times of retrying is not correct

The times of retrying was 'max_retries' plus 1 which is fixed now.
celery · Jan 22, 2022 · 5bed2a8f983a3bf61c12443e7704ffd89991ef9a · 5bed2a8
1 parent a7355ac
commit 5bed2a8f983a3bf61c12443e7704ffd89991ef9a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kombu/connection.py b/kombu/connection.py
@@ -529,7 +529,7 @@ def _ensured(*args, **kwargs):
                             # the error if it persists after a new connection
                             # was successfully established.
                             raise
-                        if max_retries is not None and retries > max_retries:
+                        if max_retries is not None and retries >= max_retries:
                             raise
                         self._debug('ensure connection error: %r',
                                     exc, exc_info=1)