(self, r)
| 221 | await lock.release() |
| 222 | |
| 223 | async def test_extend_lock_replace_ttl(self, r): |
| 224 | lock = self.get_lock(r, "foo", timeout=10) |
| 225 | assert await lock.acquire(blocking=False) |
| 226 | assert 8000 < (await r.pttl("foo")) <= 10000 |
| 227 | assert await lock.extend(10, replace_ttl=True) |
| 228 | assert 8000 < (await r.pttl("foo")) <= 10000 |
| 229 | await lock.release() |
| 230 | |
| 231 | async def test_extend_lock_float(self, r): |
| 232 | lock = self.get_lock(r, "foo", timeout=10.5) |