@@ -619,37 +619,12 @@ async def test_multiple_semaphores_different_keys(
619619 key2 = faker .pystr ()
620620 capacity = 1
621621
622- sem1 = DistributedSemaphore (
623- redis_client = redis_client_sdk , key = key1 , capacity = capacity
624- )
625- sem2 = DistributedSemaphore (
626- redis_client = redis_client_sdk , key = key2 , capacity = capacity
627- )
628-
629- # Both should be able to acquire since they have different keys
630- assert await sem1 .acquire () is True
631- assert await sem2 .acquire () is True
632-
633- await sem1 .release ()
634- await sem2 .release ()
635-
636-
637- async def test_semaphore_acquire_after_release (
638- redis_client_sdk : RedisClientSDK ,
639- semaphore_name : str ,
640- semaphore_capacity : int ,
641- ):
642- """Test that semaphore can be acquired again after release"""
643- semaphore = DistributedSemaphore (
644- redis_client = redis_client_sdk , key = semaphore_name , capacity = semaphore_capacity
645- )
646-
647- # Acquire, release, acquire again
648- await semaphore .acquire ()
649- await semaphore .release ()
650-
651- result = await semaphore .acquire ()
652- assert result is True
653- assert semaphore ._acquired is True
654-
655- await semaphore .release ()
622+ async with (
623+ DistributedSemaphore (
624+ redis_client = redis_client_sdk , key = key1 , capacity = capacity
625+ ),
626+ DistributedSemaphore (
627+ redis_client = redis_client_sdk , key = key2 , capacity = capacity
628+ ),
629+ ):
630+ ...
0 commit comments