diff options
| author | Marc Schöchlin <ms-github@256bit.org> | 2023-04-27 16:18:09 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-04-27 17:18:09 +0300 |
| commit | 8e0b84d8a25c90070817c911af266cd5cabe1604 (patch) | |
| tree | 5383b8e6d827e6d8d67251f97ca7aa8ba89330ac /redis/asyncio/sentinel.py | |
| parent | fddd3d6b306724988249d117cd9e405ac78ffecc (diff) | |
| download | redis-py-8e0b84d8a25c90070817c911af266cd5cabe1604.tar.gz | |
Improve error output for master discovery (#2720)
Make MasterNotFoundError exception more precise in the case of
ConnectionError and TimeoutError to help the user to identify
configuration errors
Co-authored-by: Marc Schöchlin <marc.schoechlin@flipapp.de>
Diffstat (limited to 'redis/asyncio/sentinel.py')
| -rw-r--r-- | redis/asyncio/sentinel.py | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/redis/asyncio/sentinel.py b/redis/asyncio/sentinel.py index c3c0f91..9147ed8 100644 --- a/redis/asyncio/sentinel.py +++ b/redis/asyncio/sentinel.py @@ -254,10 +254,12 @@ class Sentinel(AsyncSentinelCommands): Returns a pair (address, port) or raises MasterNotFoundError if no master is found. """ + collected_errors = list() for sentinel_no, sentinel in enumerate(self.sentinels): try: masters = await sentinel.sentinel_masters() - except (ConnectionError, TimeoutError): + except (ConnectionError, TimeoutError) as e: + collected_errors.append(f"{sentinel} - {e!r}") continue state = masters.get(service_name) if state and self.check_master_state(state, service_name): @@ -267,7 +269,11 @@ class Sentinel(AsyncSentinelCommands): self.sentinels[0], ) return state["ip"], state["port"] - raise MasterNotFoundError(f"No master found for {service_name!r}") + + error_info = "" + if len(collected_errors) > 0: + error_info = f" : {', '.join(collected_errors)}" + raise MasterNotFoundError(f"No master found for {service_name!r}{error_info}") def filter_slaves( self, slaves: Iterable[Mapping] |