diff --git a/kombu/connection.py b/kombu/connection.py index d30b58364..b90bed99b 100644 --- a/kombu/connection.py +++ b/kombu/connection.py @@ -560,6 +560,7 @@ def _ensured(*args, **kwargs): self._debug('ensure retry policy error: %r', exc, exc_info=1) except conn_errors as exc: + self.maybe_switch_next() # select next host if got_connection and not has_modern_errors: # transport can not distinguish between # recoverable/irrecoverable errors, so we propagate