mirror of
https://github.com/norohind/jubilant-system-core.git
synced 2026-10-22 23:02:08 +03:00
All network requests use timeout
This commit is contained in:
2 files changed
+6
-1
No files matched your search
@@ -34,7 +34,7 @@ class BearerManager:
|
||||
|
||||
def _request(self, _endpoint: Endpoints) -> requests.Response:
|
||||
endpoint = self.base_address + _endpoint.value
|
||||
return self.session.get(url=endpoint, headers={'auth': self.demb_capi_auth})
|
||||
return self.session.get(url=endpoint, headers={'auth': self.demb_capi_auth}, timeout=10)
|
||||
|
||||
|
||||
class BearerManagerException(Exception):
|
||||
|
||||
@@ -85,12 +85,17 @@ def request(url: str, method: str = 'get', **kwargs) -> requests.Response:
|
||||
method=method,
|
||||
url=url,
|
||||
headers={'Authorization': f'Bearer {bearer_manager.get_random_bearer()}'},
|
||||
timeout=10,
|
||||
**kwargs
|
||||
)
|
||||
|
||||
logger.debug(f'Request complete, code {proxiedFapiRequest.status_code!r}, len '
|
||||
f'{len(proxiedFapiRequest.content)}')
|
||||
|
||||
except requests.exceptions.Timeout as e:
|
||||
logger.opt(exception=e).error(f'Exception during request {method} {url!r} {kwargs!r}')
|
||||
continue
|
||||
|
||||
except requests.exceptions.ConnectionError as e:
|
||||
logger.error(f'Proxy {proxy.url} is invalid: {str(e.__class__.__name__)}')
|
||||
continue
|
||||
|
||||
Reference in new issue
Block a user