Resolve failing unittest

Author: kristjanvalur

redis/asyncio/connection.py

@@ -906,7 +906,7 @@ async def send_packed_command(
             raise ConnectionError(
                 f"Error {err_no} while writing to socket. {errmsg}."
             ) from e
-        except BaseException:
+        except Exception:
             await self.disconnect()
             raise
 
@@ -949,7 +949,7 @@ async def read_response(self, disable_decoding: bool = False):
             raise ConnectionError(
                 f"Error while reading from {self.host}:{self.port} : {e.args}"
             )
-        except BaseException:
+        except Exception:
             await self.disconnect()
             raise
 
@@ -981,7 +981,7 @@ async def read_response_without_lock(self, disable_decoding: bool = False):
             raise ConnectionError(
                 f"Error while reading from {self.host}:{self.port} : {e.args}"
             )
-        except BaseException:
+        except Exception:
             await self.disconnect()
             raise
 

redis/connection.py

@@ -790,7 +790,7 @@ def send_packed_command(self, command, check_health=True):
                 errno = e.args[0]
                 errmsg = e.args[1]
             raise ConnectionError(f"Error {errno} while writing to socket. {errmsg}.")
-        except BaseException:
+        except Exception:
             self.disconnect()
             raise
 
@@ -828,7 +828,7 @@ def read_response(self, disable_decoding=False):
         except OSError as e:
             self.disconnect()
             raise ConnectionError(f"Error while reading from {hosterr}" f" : {e.args}")
-        except BaseException:
+        except Exception:
             self.disconnect()
             raise
 

tests/test_asyncio/test_pubsub.py

@@ -918,7 +918,6 @@ async def loop_step_listen(self):
             return False
 
 
-@pytest.mark.xfail
 @pytest.mark.onlynoncluster
 class TestBaseException:
     @pytest.mark.skipif(

tests/test_pubsub.py

@@ -737,7 +737,6 @@ def loop_step_listen(self):
             return True
 
 
-@pytest.mark.xfail
 @pytest.mark.onlynoncluster
 class TestBaseException:
     def test_base_exception(self, r: redis.Redis):