Fix test

Author: Nikos Papailiou

apis/python/src/tiledb/vector_search/ingestion.py

@@ -1743,14 +1743,12 @@ def consolidate_and_vacuum(
             conf = tiledb.Config(config)
             conf["sm.consolidation.mode"] = mode
             conf["sm.vacuum.mode"] = mode
-            # TODO consolidate remote arrays when this is supported in tiledb API
-            if not index_group_uri.startswith("tiledb://"):
-                ids_uri = group[IDS_ARRAY_NAME].uri
-                parts_uri = group[PARTS_ARRAY_NAME].uri
-                tiledb.consolidate(parts_uri, config=conf)
-                tiledb.vacuum(parts_uri, config=conf)
-                tiledb.consolidate(ids_uri, config=conf)
-                tiledb.vacuum(ids_uri, config=conf)
+            ids_uri = group[IDS_ARRAY_NAME].uri
+            parts_uri = group[PARTS_ARRAY_NAME].uri
+            tiledb.consolidate(parts_uri, config=conf)
+            tiledb.vacuum(parts_uri, config=conf)
+            tiledb.consolidate(ids_uri, config=conf)
+            tiledb.vacuum(ids_uri, config=conf)
 
         # TODO remove temp data for tiledb URIs
         if not index_group_uri.startswith("tiledb://"):

apis/python/test/test_cloud.py

@@ -13,10 +13,11 @@
 class CloudTests(unittest.TestCase):
     def setUp(self):
         super().setUp()
+        tiledb.cloud.login(token=os.getenv("TILEDB_REST_TOKEN"))
         self.namespace, storage_path, _ = groups._default_ns_path_cred()
+        storage_path = storage_path.replace("//", "/").replace("/", "//", 1)
         rand_name = random_name("vector_search")
         self.test_path = f"tiledb://{self.namespace}/{storage_path}/{rand_name}"
-        tiledb.cloud.login(token=os.getenv("TILEDB_REST_TOKEN"))
         self.config = tiledb.cloud.Config()
         self.config_dict = self.config.dict()