Skip to content

Commit

Permalink
[PR #9405/b96b01b backport][3.10] Only create the connection closed e…
Browse files Browse the repository at this point in the history
…xception once (#9410)
  • Loading branch information
bdraco authored Oct 3, 2024
1 parent 978ed74 commit 08ada3e
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion aiohttp/client_reqrep.py
Original file line number Diff line number Diff line change
Expand Up @@ -829,6 +829,9 @@ async def _on_headers_request_sent(
await trace.send_request_headers(method, url, headers)


_CONNECTION_CLOSED_EXCEPTION = ClientConnectionError("Connection closed")


class ClientResponse(HeadersMixin):

# Some of these attributes are None when created,
Expand Down Expand Up @@ -1188,7 +1191,7 @@ def _cleanup_writer(self) -> None:
def _notify_content(self) -> None:
content = self.content
if content and content.exception() is None:
set_exception(content, ClientConnectionError("Connection closed"))
set_exception(content, _CONNECTION_CLOSED_EXCEPTION)
self._released = True

async def wait_for_close(self) -> None:
Expand Down

0 comments on commit 08ada3e

Please sign in to comment.