projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
3609: --job and --pipeline logging implemented, needs testing
[arvados.git]
/
sdk
/
python
/
arvados
/
util.py
diff --git
a/sdk/python/arvados/util.py
b/sdk/python/arvados/util.py
index ada1aec6eff677f795c406785bc84129fb75cb2e..2609f112fe31d050a5a1db094e32ca8087774c5c 100644
(file)
--- a/
sdk/python/arvados/util.py
+++ b/
sdk/python/arvados/util.py
@@
-338,12
+338,12
@@
def is_hex(s, *length_args):
good_len = True
return bool(good_len and HEX_RE.match(s))
good_len = True
return bool(good_len and HEX_RE.match(s))
-def list_all(fn, **kwargs):
+def list_all(fn,
num_retries=0,
**kwargs):
items = []
offset = 0
items_available = sys.maxint
while len(items) < items_available:
items = []
offset = 0
items_available = sys.maxint
while len(items) < items_available:
- c = fn(offset=offset, **kwargs).execute()
+ c = fn(offset=offset, **kwargs).execute(
num_retries=num_retries
)
items += c['items']
items_available = c['items_available']
offset = c['offset'] + len(c['items'])
items += c['items']
items_available = c['items_available']
offset = c['offset'] + len(c['items'])