@@ -3914,54 +3914,6 @@ async def error_handler(e):
39143914
39153915 await nc .close ()
39163916
3917- @async_test
3918- async def test_kv_delete_with_ttl (self ):
3919- """Test that delete() supports msg_ttl parameter for the delete marker"""
3920- errors = []
3921-
3922- async def error_handler (e ):
3923- print ("Error:" , e , type (e ))
3924- errors .append (e )
3925-
3926- nc = await nats .connect (error_cb = error_handler )
3927-
3928- server_version = nc .connected_server_version
3929- if server_version .major == 2 and server_version .minor < 11 :
3930- pytest .skip ("per-message TTL requires nats-server v2.11.0 or later" )
3931-
3932- js = nc .jetstream ()
3933-
3934- # Create a KV bucket
3935- kv = await js .create_key_value (bucket = "TEST_TTL_DELETE" , history = 10 )
3936-
3937- # Put a key
3938- seq = await kv .put ("city" , b"paris" )
3939- assert seq == 1
3940-
3941- # Verify the key exists
3942- entry = await kv .get ("city" )
3943- assert entry .value == b"paris"
3944-
3945- # Delete with TTL of 2 seconds on the delete marker
3946- await kv .delete ("city" , msg_ttl = 2.0 )
3947-
3948- # Key should be deleted immediately
3949- with pytest .raises (KeyNotFoundError ):
3950- await kv .get ("city" )
3951-
3952- # The delete marker should exist in the stream
3953- status = await kv .status ()
3954- # After delete, there should be both the original message and delete marker
3955- assert status .values >= 1
3956-
3957- # Wait for the delete marker TTL to expire (2 seconds + buffer)
3958- await asyncio .sleep (2.5 )
3959-
3960- # The marker itself should now be removed from the stream
3961- # Note: This behavior depends on server version and configuration
3962-
3963- await nc .close ()
3964-
39653917 @async_test
39663918 async def test_kv_put_no_ttl (self ):
39673919 """Test that put() does NOT support TTL (should not have msg_ttl parameter)"""
0 commit comments