diff --git a/redis/connection.py b/redis/connection.py index a349a0f23b..c1fcb59727 100755 --- a/redis/connection.py +++ b/redis/connection.py @@ -1303,7 +1303,7 @@ def get_connection(self, command_name, *keys, **options): try: if connection.can_read(): raise ConnectionError("Connection has data") - except ConnectionError: + except (ConnectionError, OSError): connection.disconnect() connection.connect() if connection.can_read():