encode/httpx
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Drop connections from pool on connection exceptions

Browse Source
This commit is contained in:
Tom Christie 2019-04-25 17:16:37 +01:00
parent 6d35506277
commit ddf1cec65a
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
httpcore/connection_pool.py
View File

@ -110,7 +110,12 @@ class ConnectionPool(Client):
timeout: typing.Optional[TimeoutConfig] = None,
) -> Response:
connection = await self.acquire_connection(request.url.origin, timeout=timeout)
response = await connection.send(request, ssl=ssl, timeout=timeout)
try:
response = await connection.send(request, ssl=ssl, timeout=timeout)
except BaseException as exc:
self.active_connections.remove(connection)
self.max_connections.release()
raise exc
return response
async def acquire_connection(