diff options
| author | Sibuken <zeden123@gmail.com> | 2022-12-01 17:33:47 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-12-01 16:33:47 +0200 |
| commit | c48dc8310717344374db6a31000e92cfe1ae35f8 (patch) | |
| tree | 06d500960cd605fe6ae5b30b6f8aac5bc797e52b /tests/test_asyncio/test_lock.py | |
| parent | 2c121552faf0d39267969b62ce0c3276391b37cc (diff) | |
| download | redis-py-c48dc8310717344374db6a31000e92cfe1ae35f8.tar.gz | |
Async: added 'blocking' argument to call lock method (#2454)
Co-authored-by: Chayim <chayim@users.noreply.github.com>
Diffstat (limited to 'tests/test_asyncio/test_lock.py')
| -rw-r--r-- | tests/test_asyncio/test_lock.py | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/tests/test_asyncio/test_lock.py b/tests/test_asyncio/test_lock.py index 56387fa..15c3ec5 100644 --- a/tests/test_asyncio/test_lock.py +++ b/tests/test_asyncio/test_lock.py @@ -97,6 +97,14 @@ class TestLock: assert 8 < (await r.pttl("foo")) <= 9500 await lock.release() + async def test_blocking(self, r): + blocking = False + lock = self.get_lock(r, "foo", blocking=blocking) + assert not lock.blocking + + lock_2 = self.get_lock(r, "foo") + assert lock_2.blocking + async def test_blocking_timeout(self, r, event_loop): lock1 = self.get_lock(r, "foo") assert await lock1.acquire(blocking=False) |