@@ -533,19 +533,16 @@ def clear_history(
533533 updates_array_uri = group [
534534 storage_formats [storage_version ]["UPDATES_ARRAY_NAME" ]
535535 ].uri
536- with tiledb .open (updates_array_uri , "m" ) as A :
537- A .delete_fragments (0 , timestamp )
536+ tiledb .Array .delete_fragments (updates_array_uri , 0 , timestamp )
538537
539538 if index_type == "FLAT" :
540539 db_uri = group [storage_formats [storage_version ]["PARTS_ARRAY_NAME" ]].uri
541- with tiledb .open (db_uri , "m" ) as A :
542- A .delete_fragments (0 , timestamp )
540+ tiledb .Array .delete_fragments (db_uri , 0 , timestamp )
543541 if storage_formats [storage_version ]["IDS_ARRAY_NAME" ] in group :
544542 ids_uri = group [
545543 storage_formats [storage_version ]["IDS_ARRAY_NAME" ]
546544 ].uri
547- with tiledb .open (ids_uri , "m" ) as A :
548- A .delete_fragments (0 , timestamp )
545+ tiledb .Array .delete_fragments (ids_uri , 0 , timestamp )
549546 elif index_type == "IVF_FLAT" :
550547 db_uri = group [storage_formats [storage_version ]["PARTS_ARRAY_NAME" ]].uri
551548 centroids_uri = group [
@@ -555,14 +552,10 @@ def clear_history(
555552 storage_formats [storage_version ]["INDEX_ARRAY_NAME" ]
556553 ].uri
557554 ids_uri = group [storage_formats [storage_version ]["IDS_ARRAY_NAME" ]].uri
558- with tiledb .open (db_uri , "m" ) as A :
559- A .delete_fragments (0 , timestamp )
560- with tiledb .open (centroids_uri , "m" ) as A :
561- A .delete_fragments (0 , timestamp )
562- with tiledb .open (index_array_uri , "m" ) as A :
563- A .delete_fragments (0 , timestamp )
564- with tiledb .open (ids_uri , "m" ) as A :
565- A .delete_fragments (0 , timestamp )
555+ tiledb .Array .delete_fragments (db_uri , 0 , timestamp )
556+ tiledb .Array .delete_fragments (centroids_uri , 0 , timestamp )
557+ tiledb .Array .delete_fragments (index_array_uri , 0 , timestamp )
558+ tiledb .Array .delete_fragments (ids_uri , 0 , timestamp )
566559 group .close ()
567560
568561
0 commit comments