20637: Fix tests 20637-prefetch-threads
authorPeter Amstutz <peter.amstutz@curii.com>
Fri, 16 Jun 2023 19:46:48 +0000 (15:46 -0400)
committerPeter Amstutz <peter.amstutz@curii.com>
Fri, 16 Jun 2023 19:46:48 +0000 (15:46 -0400)
Arvados-DCO-1.1-Signed-off-by: Peter Amstutz <peter.amstutz@curii.com>

sdk/python/tests/test_arvfile.py
sdk/python/tests/test_collections.py

index 691716b3f47ce9e2842d5ea10f32d7ddc3956ff7..cf6dec1a553eec3e0bbf6b219e11eccfb0ca9b7e 100644 (file)
@@ -27,6 +27,7 @@ class ArvadosFileWriterTestCase(unittest.TestCase):
         def __init__(self, blocks):
             self.blocks = blocks
             self.requests = []
+            self.num_prefetch_threads = 1
         def get(self, locator, num_retries=0, prefetch=False):
             self.requests.append(locator)
             return self.blocks.get(locator)
@@ -37,6 +38,8 @@ class ArvadosFileWriterTestCase(unittest.TestCase):
             pdh = tutil.str_keep_locator(data)
             self.blocks[pdh] = bytes(data)
             return pdh
+        def block_prefetch(self, loc):
+            self.requests.append(loc)
 
     class MockApi(object):
         def __init__(self, b, r):
@@ -627,7 +630,7 @@ class ArvadosFileReaderTestCase(StreamFileReaderTestCase):
             def __init__(self, blocks, nocache):
                 self.blocks = blocks
                 self.nocache = nocache
-                self.num_get_threads = 1
+                self._keep = ArvadosFileWriterTestCase.MockKeep({})
 
             def block_prefetch(self, loc):
                 pass
index c79607fca9cc07af4656632a18cb5b7251f54a15..56c2352adbb613903ea815cff2098a2604bf5560 100644 (file)
@@ -323,6 +323,7 @@ class ArvadosCollectionsTest(run_test_server.TestCaseWithServers,
     class MockKeep(object):
         def __init__(self, content, num_retries=0):
             self.content = content
+            self.num_prefetch_threads = 1
 
         def get(self, locator, num_retries=0, prefetch=False):
             return self.content[locator]