(self, r)
| 38 | return redis.lock(*args, **kwargs) |
| 39 | |
| 40 | def test_lock(self, r): |
| 41 | lock = self.get_lock(r, "foo") |
| 42 | assert lock.acquire(blocking=False) |
| 43 | assert r.get("foo") == lock.local.token |
| 44 | assert r.ttl("foo") == -1 |
| 45 | lock.release() |
| 46 | assert r.get("foo") is None |
| 47 | |
| 48 | def test_lock_token(self, r): |
| 49 | lock = self.get_lock(r, "foo") |