X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/370d158d6cfd9a610e68946cc22998543ef10e3d..d071c34ca20aa86a5a053abcffb7414dbd8f4933:/sdk/python/arvados/util.py diff --git a/sdk/python/arvados/util.py b/sdk/python/arvados/util.py index 0889ffcddd..2609f112fe 100644 --- a/sdk/python/arvados/util.py +++ b/sdk/python/arvados/util.py @@ -9,6 +9,13 @@ from arvados.collection import * HEX_RE = re.compile(r'^[0-9a-fA-F]+$') +portable_data_hash_pattern = re.compile(r'[0-9a-f]{32}\+\d+') +uuid_pattern = re.compile(r'[a-z0-9]{5}-[a-z0-9]{5}-[a-z0-9]{15}') +collection_uuid_pattern = re.compile(r'[a-z0-9]{5}-4zz18-[a-z0-9]{15}') +group_uuid_pattern = re.compile(r'[a-z0-9]{5}-j7d0g-[a-z0-9]{15}') +user_uuid_pattern = re.compile(r'[a-z0-9]{5}-tpzed-[a-z0-9]{15}') +link_uuid_pattern = re.compile(r'[a-z0-9]{5}-o0j2j-[a-z0-9]{15}') + def clear_tmpdir(path=None): """ Ensure the given directory (or TASK_TMPDIR if none given) @@ -331,12 +338,12 @@ def is_hex(s, *length_args): 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: - 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'])