diff options
| -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(): |