Skip to content

Commit 1d6e444

Browse files
teo-tsirpanisihnorton
authored andcommitted
Avoid creating contexts to pass the consolidation/vacuum parameters.
1 parent e5bd745 commit 1d6e444

File tree

1 file changed

+6
-7
lines changed

1 file changed

+6
-7
lines changed

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

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1270,15 +1270,14 @@ def consolidate_and_vacuum(
12701270
conf = tiledb.Config(config)
12711271
conf["sm.consolidation.mode"] = mode
12721272
conf["sm.vacuum.mode"] = mode
1273-
ctx= tiledb.Ctx(conf)
1274-
group = tiledb.Group(array_uri, ctx=ctx)
1275-
tiledb.consolidate(group[PARTS_ARRAY_NAME].uri, ctx=ctx)
1276-
tiledb.vacuum(group[PARTS_ARRAY_NAME].uri, ctx=ctx)
1273+
group = tiledb.Group(array_uri, config=conf)
1274+
tiledb.consolidate(group[PARTS_ARRAY_NAME].uri, config=conf)
1275+
tiledb.vacuum(group[PARTS_ARRAY_NAME].uri, config=conf)
12771276
if index_type == "IVF_FLAT":
1278-
tiledb.consolidate(group[IDS_ARRAY_NAME].uri, ctx=ctx)
1279-
tiledb.vacuum(group[IDS_ARRAY_NAME].uri, ctx=ctx)
1277+
tiledb.consolidate(group[IDS_ARRAY_NAME].uri, config=conf)
1278+
tiledb.vacuum(group[IDS_ARRAY_NAME].uri, config=conf)
12801279

1281-
vfs = tiledb.VFS()
1280+
vfs = tiledb.VFS(config)
12821281
partial_write_array_dir_uri = array_uri + "/" + PARTIAL_WRITE_ARRAY_DIR
12831282
if vfs.is_dir(partial_write_array_dir_uri):
12841283
vfs.remove_dir(partial_write_array_dir_uri)

0 commit comments

Comments
 (0)