diff options
| author | 송형근(Hyeongguen Song)/DnU <87850472+hyeongguen-song@users.noreply.github.com> | 2022-10-26 00:14:37 +0900 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-10-25 18:14:37 +0300 |
| commit | bea00b16c8043397c6bb6f3df45d48bceefa685f (patch) | |
| tree | add61e09785daab99cc1fae2965877fe403a43cf | |
| parent | 9d70719840d9831ea40904a36038fcd0e3fdff65 (diff) | |
| download | redis-py-bea00b16c8043397c6bb6f3df45d48bceefa685f.tar.gz | |
fix: catch OSError on asyncio (#2412)
| -rw-r--r-- | redis/asyncio/connection.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/redis/asyncio/connection.py b/redis/asyncio/connection.py index c8834c9..bc0362e 100644 --- a/redis/asyncio/connection.py +++ b/redis/asyncio/connection.py @@ -1445,7 +1445,7 @@ class ConnectionPool: try: if await connection.can_read_destructive(): raise ConnectionError("Connection has data") from None - except ConnectionError: + except (ConnectionError, OSError): await connection.disconnect() await connection.connect() if await connection.can_read_destructive(): @@ -1646,7 +1646,7 @@ class BlockingConnectionPool(ConnectionPool): try: if await connection.can_read_destructive(): raise ConnectionError("Connection has data") from None - except ConnectionError: + except (ConnectionError, OSError): await connection.disconnect() await connection.connect() if await connection.can_read_destructive(): |