Skip to content

Commit b1a1849

Browse files
committed
fix lock delete method
1 parent 202e4b5 commit b1a1849

File tree

1 file changed

+1
-21
lines changed

1 file changed

+1
-21
lines changed

ydb/aio/coordination/lock.py

Lines changed: 1 addition & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -154,28 +154,8 @@ async def create(self, init_limit, init_data):
154154
resp = await self._wait_for_response(req_id, kind="create")
155155
return CreateSemaphoreResult.from_proto(resp)
156156

157-
async def delete(self, wait_empty_timeout: float = 5.0, poll_interval: float = 0.05):
157+
async def delete(self):
158158
await self._ensure_session()
159-
160-
deadline = asyncio.get_running_loop().time() + wait_empty_timeout
161-
while True:
162-
try:
163-
desc = await self.describe()
164-
if desc.count == 0 and not desc.owners:
165-
break
166-
except issues.Error as e:
167-
if getattr(e, "status", None) == StatusCode.NOT_FOUND:
168-
break
169-
raise
170-
171-
now = asyncio.get_running_loop().time()
172-
if now > deadline:
173-
raise issues.Error(
174-
f"Timeout waiting for semaphore '{self._name}' to become empty before delete. "
175-
f"count={desc.count}, owners={list(desc.owners)}"
176-
)
177-
await asyncio.sleep(poll_interval)
178-
179159
req_id = self.next_req_id()
180160
req = DeleteSemaphore(req_id=req_id, name=self._name)
181161
await self.send(req)

0 commit comments

Comments
 (0)