@@ -79,6 +79,9 @@ async def vector_index_test_state(request):
7979
8080@pytest .mark .usefixtures ("delete_vec_params" , "setup_and_teardown" )
8181class TestAsyncDeleteVectorIndex :
82+ def resource_name (self , name : str ) -> str :
83+ return f"{ name } _{ self .delete_vec_params ['resource_suffix' ]} "
84+
8285 @classmethod
8386 def get_native_cred_param (cls , cred_name = None ) -> dict :
8487 logger .info ("Preparing native credential params for: %s" , cred_name )
@@ -420,14 +423,16 @@ async def test_5108(self):
420423 async def test_5109 (self ):
421424 """Test delete of a nonexistent index (should not error)."""
422425 idx = select_ai .AsyncVectorIndex (
423- index_name = "nonexistent_index" ,
426+ index_name = self . resource_name ( "nonexistent_index" ) ,
424427 attributes = self .vector_index_attributes ,
425428 profile = self .profile ,
426429 )
427430 logger .info ("Attempting to delete nonexistent index" )
428431 await idx .delete (force = True )
429432 await asyncio .sleep (1 )
430- await self .assert_index_count ("^nonexistent_index" , 0 )
433+ await self .assert_index_count (
434+ f"^{ self .resource_name ('nonexistent_index' )} $" , 0
435+ )
431436 logger .info ("Nonexistent delete verified (no error)" )
432437
433438 async def test_5110 (self ):
@@ -458,7 +463,7 @@ async def test_5110(self):
458463 async def test_5111 (self ):
459464 """Test case-sensitive name for create and delete."""
460465 idx = select_ai .AsyncVectorIndex (
461- index_name = "CaseSensitiveIndex" ,
466+ index_name = self . resource_name ( "CaseSensitiveIndex" ) ,
462467 attributes = self .vector_index_attributes ,
463468 profile = self .profile ,
464469 )
@@ -467,12 +472,14 @@ async def test_5111(self):
467472 logger .info ("Deleting case-sensitive index" )
468473 await idx .delete (force = True )
469474 await asyncio .sleep (1 )
470- await self .assert_index_count ("^CaseSensitiveIndex" , 0 )
475+ await self .assert_index_count (
476+ f"^{ self .resource_name ('CaseSensitiveIndex' )} $" , 0
477+ )
471478 logger .info ("Case-sensitive index delete verified" )
472479
473480 async def test_5112 (self ):
474481 """Test creation and deletion with long index name."""
475- long_name = "index_" + "x" * 40
482+ long_name = self . resource_name ( "index_" + "x" * 40 )
476483 idx = select_ai .AsyncVectorIndex (
477484 index_name = long_name ,
478485 attributes = self .vector_index_attributes ,
@@ -488,7 +495,10 @@ async def test_5112(self):
488495
489496 async def test_5113 (self ):
490497 """Test creation and bulk deletion of indexes."""
491- names = [f"bulk_idx_{ i } " for i in range (3 )]
498+ names = [
499+ f"bulk_idx_{ self .delete_vec_params ['resource_suffix' ]} _{ i } "
500+ for i in range (3 )
501+ ]
492502 logger .info ("Creating bulk indexes" )
493503 for name in names :
494504 await select_ai .AsyncVectorIndex (
@@ -506,7 +516,9 @@ async def test_5113(self):
506516 ).delete (force = True )
507517 await asyncio .sleep (1 )
508518 logger .info ("Deleted %s" , name )
509- await self .assert_index_count ("^bulk_idx_" , 0 )
519+ await self .assert_index_count (
520+ f"^bulk_idx_{ self .delete_vec_params ['resource_suffix' ]} _" , 0
521+ )
510522 logger .info ("Bulk delete verified" )
511523
512524 async def test_5114 (self ):
@@ -545,24 +557,26 @@ async def test_5115(self):
545557 async def test_5116 (self ):
546558 """Test delete of one out of multiple indexes."""
547559 idx1 = select_ai .AsyncVectorIndex (
548- index_name = "IDX_1" ,
560+ index_name = self . resource_name ( "IDX_1" ) ,
549561 attributes = self .vector_index_attributes ,
550562 profile = self .profile ,
551563 )
552564 idx2 = select_ai .AsyncVectorIndex (
553- index_name = "IDX_2" ,
565+ index_name = self . resource_name ( "IDX_2" ) ,
554566 attributes = self .vector_index_attributes ,
555567 profile = self .profile ,
556568 )
557- logger .info ("Creating two indexes IDX_1 and IDX_2 " )
569+ logger .info ("Creating two isolated indexes " )
558570 await idx1 .create (replace = True )
559571 await idx2 .create (replace = True )
560572 logger .info ("Deleting IDX_1 only" )
561- await self .delete_and_wait (force = True , pattern = "^IDX_1$" )
573+ await self .delete_and_wait (
574+ force = True , pattern = f"^{ self .resource_name ('IDX_1' )} $"
575+ )
562576 remaining_idx2 = [
563577 index
564578 async for index in self .async_vector_index .list (
565- index_name_pattern = "^ IDX_2$"
579+ index_name_pattern = f"^ { self . resource_name ( ' IDX_2' ) } $"
566580 )
567581 ]
568582 logger .info ("IDX_2 entries after IDX_1 delete: %s" , remaining_idx2 )
0 commit comments