(self, additional_time, replace_ttl)
| 313 | return self.do_extend(additional_time, replace_ttl) |
| 314 | |
| 315 | async def do_extend(self, additional_time, replace_ttl) -> Literal[True]: |
| 316 | additional_time = int(additional_time * 1000) |
| 317 | if not bool( |
| 318 | await self.lua_extend( |
| 319 | keys=[self.name], |
| 320 | args=[self.local.token, additional_time, replace_ttl and "1" or "0"], |
| 321 | client=self.redis, |
| 322 | ) |
| 323 | ): |
| 324 | raise LockNotOwnedError("Cannot extend a lock that's no longer owned") |
| 325 | return True |
| 326 | |
| 327 | def reacquire(self) -> Awaitable[Literal[True]]: |
| 328 | """ |
no test coverage detected