(headers=None)
| 24 | |
| 25 | |
| 26 | def create_session(headers=None): |
| 27 | session = requests.Session() |
| 28 | |
| 29 | retry_strategy = Retry( |
| 30 | total=3, |
| 31 | backoff_factor=1, |
| 32 | status_forcelist=[500, 502, 503, 504], |
| 33 | allowed_methods=["HEAD", "GET", "POST", "PUT", "DELETE", "OPTIONS"], |
| 34 | ) |
| 35 | |
| 36 | adapter = HTTPAdapter(max_retries=retry_strategy) |
| 37 | session.mount("https://", adapter) |
| 38 | session.mount("http://", adapter) |
| 39 | |
| 40 | if cv.proxy: |
| 41 | session.proxies = {"http": cv.proxy, "https": cv.proxy} |
| 42 | |
| 43 | session.hooks['response'].append(_rate_limit_hook) |
| 44 | |
| 45 | if headers: |
| 46 | session.headers.update(headers) |
| 47 | |
| 48 | return session |
no outgoing calls
no test coverage detected