Pass arguments from instance dict to urlopen in HTTPAdapter.send

psf · Sep 12, 2023 · 1c45439 · 1c45439
1 parent 8812812
commit 1c45439
Showing 1 changed file with 20 additions and 14 deletions.
diff --git a/src/requests/adapters.py b/src/requests/adapters.py
@@ -154,6 +154,8 @@ def __init__(
 
         self.init_poolmanager(pool_connections, pool_maxsize, block=pool_block)
 
+        self.urllib3_response_options = {}
+
     def __getstate__(self):
         return {attr: getattr(self, attr, None) for attr in self.__attrs__}
 
@@ -455,7 +457,6 @@ def send(
             raise InvalidURL(e, request=request)
 
         self.cert_verify(conn, request.url, verify, cert)
-        url = self.request_url(request, proxies)
         self.add_headers(
             request,
             stream=stream,
@@ -481,20 +482,25 @@ def send(
         else:
             timeout = TimeoutSauce(connect=timeout, read=timeout)
 
+        urlopen_kwargs = self.urllib3_response_options.copy()
+        urlopen_kwargs.update(
+            {
+                "method": request.method,
+                "url": self.request_url(request, proxies),
+                "body": request.body,
+                "headers": request.headers,
+                "redirect": False,
+                "assert_same_host": False,
+                "preload_content": False,
+                "decode_content": False,
+                "retries": self.max_retries,
+                "timeout": timeout,
+                "chunked": chunked,
+            }
+        )
+
         try:
-            resp = conn.urlopen(
-                method=request.method,
-                url=url,
-                body=request.body,
-                headers=request.headers,
-                redirect=False,
-                assert_same_host=False,
-                preload_content=False,
-                decode_content=False,
-                retries=self.max_retries,
-                timeout=timeout,
-                chunked=chunked,
-            )
+            resp = conn.urlopen(**urlopen_kwargs)
 
         except (ProtocolError, OSError) as err:
             raise ConnectionError(err, request=request)