projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Arvados-DCO-1.1-Signed-off-by: Radhika Chippada <radhika@curoverse.com>
[arvados.git]
/
sdk
/
python
/
arvados
/
util.py
diff --git
a/sdk/python/arvados/util.py
b/sdk/python/arvados/util.py
index e2692b738aa16a945d2d3935d39bae3030f5c687..97e1d26d2ba2e1cf7ad503ab80b2974676c87cf8 100644
(file)
--- a/
sdk/python/arvados/util.py
+++ b/
sdk/python/arvados/util.py
@@
-1,3
+1,7
@@
+# Copyright (C) The Arvados Authors. All rights reserved.
+#
+# SPDX-License-Identifier: Apache-2.0
+
import fcntl
import hashlib
import httplib2
import fcntl
import hashlib
import httplib2
@@
-124,7
+128,7
@@
def tarball_extract(tarball, path):
raise arvados.errors.CommandFailedError(
"tar exited %d" % p.returncode)
os.symlink(tarball, os.path.join(path, '.locator'))
raise arvados.errors.CommandFailedError(
"tar exited %d" % p.returncode)
os.symlink(tarball, os.path.join(path, '.locator'))
- tld_extracts =
filter(lambda f: f != '.locator', os.listdir(path))
+ tld_extracts =
[f for f in os.listdir(path) if f != '.locator']
lockfile.close()
if len(tld_extracts) == 1:
return os.path.join(path, tld_extracts[0])
lockfile.close()
if len(tld_extracts) == 1:
return os.path.join(path, tld_extracts[0])
@@
-190,7
+194,7
@@
def zipball_extract(zipball, path):
"unzip exited %d" % p.returncode)
os.unlink(zip_filename)
os.symlink(zipball, os.path.join(path, '.locator'))
"unzip exited %d" % p.returncode)
os.unlink(zip_filename)
os.symlink(zipball, os.path.join(path, '.locator'))
- tld_extracts =
filter(lambda f: f != '.locator', os.listdir(path))
+ tld_extracts =
[f for f in os.listdir(path) if f != '.locator']
lockfile.close()
if len(tld_extracts) == 1:
return os.path.join(path, tld_extracts[0])
lockfile.close()
if len(tld_extracts) == 1:
return os.path.join(path, tld_extracts[0])
@@
-364,10
+368,10
@@
def is_hex(s, *length_args):
def list_all(fn, num_retries=0, **kwargs):
# Default limit to (effectively) api server's MAX_LIMIT
def list_all(fn, num_retries=0, **kwargs):
# Default limit to (effectively) api server's MAX_LIMIT
- kwargs.setdefault('limit', sys.max
int
)
+ kwargs.setdefault('limit', sys.max
size
)
items = []
offset = 0
items = []
offset = 0
- items_available = sys.max
int
+ items_available = sys.max
size
while len(items) < items_available:
c = fn(offset=offset, **kwargs).execute(num_retries=num_retries)
items += c['items']
while len(items) < items_available:
c = fn(offset=offset, **kwargs).execute(num_retries=num_retries)
items += c['items']