mirror/github-octodns
1
0
Fork 0
mirror of https://github.com/github/octodns.git synced 2024-05-11 05:55:00 +00:00
Code Issues Releases Activity

UltraDNS adding configurable HTTP request timeout

Browse Source
This commit is contained in:
Phelps Williams
2020-07-13 17:46:24 -07:00
parent 5c0d5831ac
commit d078392bbc
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
octodns/provider/ultra.py
View File

@@ -77,13 +77,13 @@ class UltraProvider(BaseProvider):
data=None, json=None, json_response=True): data=None, json=None, json_response=True):
self.log.debug('_request: method=%s, path=%s', method, path) self.log.debug('_request: method=%s, path=%s', method, path)
url = '{}{}'.format(self.base_uri, path) url = '{}{}'.format(self._base_uri, path)
resp = self._sess.request(method, resp = self._sess.request(method,
url, url,
params=params, params=params,
data=data, data=data,
json=json, json=json,
timeout=self.TIMEOUT) timeout=self._timeout)
self.log.debug('_request: status=%d', resp.status_code) self.log.debug('_request: status=%d', resp.status_code)
if resp.status_code == 401: if resp.status_code == 401:
@@ -129,16 +129,21 @@ class UltraProvider(BaseProvider):
'Authorization': 'Bearer {}'.format(resp['access_token']), 'Authorization': 'Bearer {}'.format(resp['access_token']),
}) })
def __init__(self, id, account, username, password, *args, **kwargs): def __init__(self, id, account, username, password, timeout=TIMEOUT,
*args, **kwargs):
self.log = getLogger('UltraProvider[{}]'.format(id)) self.log = getLogger('UltraProvider[{}]'.format(id))
self.log.debug('__init__: id=%s, account=%s, username=%s, ' self.log.debug('__init__: id=%s, account=%s, username=%s, '
'password=***', id, account, username) 'password=***', id, account, username)
super(UltraProvider, self).__init__(id, *args, **kwargs) super(UltraProvider, self).__init__(id, *args, **kwargs)
self.base_uri = 'https://restapi.ultradns.com'
self._base_uri = 'https://restapi.ultradns.com'
self._sess = Session() self._sess = Session()
self._login(username, password)
self._account = account self._account = account
self._timeout = timeout
self._login(username, password)
self._zones = None self._zones = None
self._zone_records = {} self._zone_records = {}