Skip to content

Commit

Permalink
Fixed python to set exception to the poped future called for the clos…
Browse files Browse the repository at this point in the history
…ing error
  • Loading branch information
barshaul committed Jan 28, 2024
1 parent 75ee83c commit 17403b6
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions python/python/glide/redis_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -264,6 +264,8 @@ async def _reader_loop(self) -> None:
if response.HasField("closing_error")
else f"Client Error - closing due to unknown error. callback index: {response.callback_idx}"
)
if res_future is not None:
res_future.set_exception(ClosingError(err_msg))
await self.close(err_msg)
raise ClosingError(err_msg)
else:
Expand Down

0 comments on commit 17403b6

Please sign in to comment.