Skip to content
This repository was archived by the owner on Feb 21, 2023. It is now read-only.

Commit a5bb394

Browse files
Auto-reconnect PubSub on get_message (redis/redis-py#1574) * Thank you Theron Luhn <@luhn>!!! * Fixes #1130 Signed-off-by: Andrew-Chen-Wang <[email protected]>
1 parent e64ae81 commit a5bb394

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

CONTRIBUTORS.txt

+1
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,7 @@ Stanislau Arkhipenka
6161
Taku Fukada
6262
Taras Voinarovskyi
6363
Thanos Lefteris
64+
Theron Luhn <luhn>
6465
Thomas Steinacher
6566
Volodymyr Hotsyk
6667
Youngmin Koo <youngminz>

aioredis/client.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -1342,7 +1342,7 @@ async def parse_response(self, block: bool = True, timeout: float = 0):
13421342

13431343
await self.check_health()
13441344

1345-
if not block and not await conn.can_read(timeout=timeout):
1345+
if not block and not await self._execute(conn, conn.can_read, timeout=timeout):
13461346
return None
13471347
response = await self._execute(conn, conn.read_response)
13481348

0 commit comments

Comments
 (0)