fix (#2799)

redis · Jun 14, 2023 · e13b239 · e13b239
1 parent 5f49e05
commit e13b239
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/redis/asyncio/connection.py b/redis/asyncio/connection.py
@@ -514,7 +514,7 @@ async def read_response(
         try:
             if (
                 read_timeout is not None
-                and self.protocol == "3"
+                and self.protocol in ["3", 3]
                 and not HIREDIS_AVAILABLE
             ):
                 async with async_timeout(read_timeout):
@@ -526,7 +526,7 @@ async def read_response(
                     response = await self._parser.read_response(
                         disable_decoding=disable_decoding
                     )
-            elif self.protocol == "3" and not HIREDIS_AVAILABLE:
+            elif self.protocol in ["3", 3] and not HIREDIS_AVAILABLE:
                 response = await self._parser.read_response(
                     disable_decoding=disable_decoding, push_request=push_request
                 )

diff --git a/redis/connection.py b/redis/connection.py
@@ -433,7 +433,7 @@ def read_response(self, disable_decoding=False, push_request=False):
         host_error = self._host_error()
 
         try:
-            if self.protocol == "3" and not HIREDIS_AVAILABLE:
+            if self.protocol in ["3", 3] and not HIREDIS_AVAILABLE:
                 response = self._parser.read_response(
                     disable_decoding=disable_decoding, push_request=push_request
                 )