|
4 | 4 | import time |
5 | 5 |
|
6 | 6 | from requests import Request, Session |
7 | | -from requests import utils |
8 | 7 | from urllib.parse import urljoin |
9 | 8 |
|
10 | 9 | import dockercloud |
@@ -55,18 +54,16 @@ def send_request(method, path, inject_header=True, **kwargs): |
55 | 54 | # construct request |
56 | 55 | s = get_session() |
57 | 56 | request = Request(method, url, headers=headers, **kwargs) |
58 | | - # get environment proxies |
59 | | - env_proxies = utils.get_environ_proxies(url) or {} |
60 | | - kw_args = {'proxies': env_proxies} |
61 | 57 |
|
62 | 58 | # make the request |
63 | 59 | req = s.prepare_request(request) |
| 60 | + proxy = s.rebuild_proxies(req, None) |
64 | 61 | logger.info("Prepared Request: %s, %s, %s, %s" % (req.method, req.url, req.headers, kwargs)) |
65 | 62 |
|
66 | 63 | if dockercloud.api_timeout: |
67 | | - response = s.send(req, timeout=dockercloud.api_timeout, **kw_args) |
| 64 | + response = s.send(req, timeout=dockercloud.api_timeout, proxies=proxy) |
68 | 65 | else: |
69 | | - response = s.send(req, **kw_args) |
| 66 | + response = s.send(req, proxies=proxy) |
70 | 67 |
|
71 | 68 | status_code = getattr(response, 'status_code', None) |
72 | 69 | logger.info("Response: Status %s, %s, %s" % (str(status_code), response.headers, response.text)) |
|
0 commit comments