projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge branch '11507-deleted-bufferblocks' refs #11507
[arvados.git]
/
sdk
/
python
/
arvados
/
api.py
diff --git
a/sdk/python/arvados/api.py
b/sdk/python/arvados/api.py
index 1af50b311020f4ed87391cd2a1e76463f39394f5..543725b516beada820f9b3e001d1267024436b02 100644
(file)
--- a/
sdk/python/arvados/api.py
+++ b/
sdk/python/arvados/api.py
@@
-44,7
+44,7
@@
class OrderedJsonModel(apiclient.model.JsonModel):
return body
return body
-def _intercept_http_request(self, uri, **kwargs):
+def _intercept_http_request(self, uri,
method="GET",
**kwargs):
if (self.max_request_size and
kwargs.get('body') and
self.max_request_size < len(kwargs['body'])):
if (self.max_request_size and
kwargs.get('body') and
self.max_request_size < len(kwargs['body'])):
@@
-58,7
+58,7
@@
def _intercept_http_request(self, uri, **kwargs):
kwargs['headers']['Authorization'] = 'OAuth2 %s' % self.arvados_api_token
kwargs['headers']['Authorization'] = 'OAuth2 %s' % self.arvados_api_token
- retryable =
kwargs.get('method', 'GET')
in [
+ retryable =
method
in [
'DELETE', 'GET', 'HEAD', 'OPTIONS', 'PUT']
retry_count = self._retry_count if retryable else 0
'DELETE', 'GET', 'HEAD', 'OPTIONS', 'PUT']
retry_count = self._retry_count if retryable else 0
@@
-75,7
+75,7
@@
def _intercept_http_request(self, uri, **kwargs):
for _ in range(retry_count):
self._last_request_time = time.time()
try:
for _ in range(retry_count):
self._last_request_time = time.time()
try:
- return self.orig_http_request(uri, **kwargs)
+ return self.orig_http_request(uri,
method,
**kwargs)
except httplib.HTTPException:
_logger.debug("Retrying API request in %d s after HTTP error",
delay, exc_info=True)
except httplib.HTTPException:
_logger.debug("Retrying API request in %d s after HTTP error",
delay, exc_info=True)
@@
-93,7
+93,7
@@
def _intercept_http_request(self, uri, **kwargs):
delay = delay * self._retry_delay_backoff
self._last_request_time = time.time()
delay = delay * self._retry_delay_backoff
self._last_request_time = time.time()
- return self.orig_http_request(uri, **kwargs)
+ return self.orig_http_request(uri,
method,
**kwargs)
def _patch_http_request(http, api_token):
http.arvados_api_token = api_token
def _patch_http_request(http, api_token):
http.arvados_api_token = api_token