X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/00693ff029257e72565148e8748941ac20cc99d1..b3f083ce49a50521d96daa28f896d857384222fb:/sdk/cwl/arvados_cwl/fsaccess.py diff --git a/sdk/cwl/arvados_cwl/fsaccess.py b/sdk/cwl/arvados_cwl/fsaccess.py index 69f918ead9..0b577b06a2 100644 --- a/sdk/cwl/arvados_cwl/fsaccess.py +++ b/sdk/cwl/arvados_cwl/fsaccess.py @@ -32,6 +32,7 @@ class CollectionCache(object): min_entries=2): self.api_client = api_client self.keep_client = keep_client + self.num_retries = num_retries self.collections = OrderedDict() self.lock = threading.Lock() self.total = 0 @@ -54,7 +55,8 @@ class CollectionCache(object): if pdh not in self.collections: logger.debug("Creating collection reader for %s", pdh) cr = arvados.collection.CollectionReader(pdh, api_client=self.api_client, - keep_client=self.keep_client) + keep_client=self.keep_client, + num_retries=self.num_retries) sz = len(cr.manifest_text()) * 128 self.collections[pdh] = (cr, sz) self.total += sz