X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/94e82b3e5e65cc8792baf0b4d5dc80ae3721760e..ec0ff33922f83bf5358252c81444ca85c7a6a630:/services/fuse/arvados_fuse/fusedir.py diff --git a/services/fuse/arvados_fuse/fusedir.py b/services/fuse/arvados_fuse/fusedir.py index f3816c0d3e..7de95a0cb1 100644 --- a/services/fuse/arvados_fuse/fusedir.py +++ b/services/fuse/arvados_fuse/fusedir.py @@ -525,23 +525,15 @@ class CollectionDirectory(CollectionDirectoryBase): self.collection.update() new_collection_record = self.collection.api_response() else: - # If there's too many prefetch threads and you - # max out the CPU, delivering data to the FUSE - # layer actually ends up being slower. - # Experimentally, capping 7 threads seems to - # be a sweet spot. - get_threads = min(max((self.api.keep.block_cache.cache_max // (64 * 1024 * 1024)) - 1, 1), 7) # Create a new collection object if uuid_pattern.match(self.collection_locator): coll_reader = arvados.collection.Collection( self.collection_locator, self.api, self.api.keep, - num_retries=self.num_retries, - get_threads=get_threads) + num_retries=self.num_retries) else: coll_reader = arvados.collection.CollectionReader( self.collection_locator, self.api, self.api.keep, - num_retries=self.num_retries, - get_threads=get_threads) + num_retries=self.num_retries) new_collection_record = coll_reader.api_response() or {} # If the Collection only exists in Keep, there will be no API # response. Fill in the fields we need.