@@ -190,7 +190,7 @@ def test_coordination_lock_describe_full_sync(self, sync_coordination_node):
190190
191191 async def test_coordination_lock_racing_async (self , async_coordination_node ):
192192 client , node_path , initial_config = async_coordination_node
193- timeout = 5 # таймаут для CI/нагрузки
193+ timeout = 5
194194
195195 lock = client .lock ("test_lock" , node_path )
196196 await lock .create (init_limit = 1 , init_data = b"init-data" )
@@ -206,7 +206,7 @@ async def second_lock_task():
206206 lock2_started .set ()
207207 async with client .lock ("test_lock" , node_path ):
208208 lock2_acquired .set ()
209- await lock2_release .wait () # вместо sleep
209+ await lock2_release .wait ()
210210
211211 async with client .lock ("test_lock" , node_path ) as lock1 :
212212 resp : DescribeLockResult = await lock1 .describe ()
@@ -215,15 +215,11 @@ async def second_lock_task():
215215 t2 = asyncio .create_task (second_lock_task ())
216216 await asyncio .wait_for (lock2_started .wait (), timeout = timeout )
217217
218- # Даем t2 шанс реально дойти до попытки acquire (не обязательно, но помогает стабильности)
219218 await asyncio .sleep (0 )
220219
221- # lock1 держится до выхода из async with
222220
223- # После освобождения lock1 второй лок обязан захватиться
224221 await asyncio .wait_for (lock2_acquired .wait (), timeout = timeout )
225222
226- # Разрешаем t2 корректно выйти и ждём завершения
227223 lock2_release .set ()
228224 await asyncio .wait_for (t2 , timeout = timeout )
229225
0 commit comments