use anyio tools in tests

Author: amirreza8002

tests/tests_async/test_backend.py

@@ -1,4 +1,3 @@
-import asyncio
 import contextlib
 import datetime
 import threading
@@ -11,6 +10,8 @@
 from pytest_django.fixtures import SettingsWrapper
 from pytest_mock import MockerFixture
 
+import anyio
+
 from django.core.cache import caches
 from django.core.cache.backends.base import DEFAULT_TIMEOUT
 from django.test import override_settings
@@ -73,15 +74,15 @@ async def test_setnx_timeout(self, cache: AsyncValkeyCache):
         # test that timeout still works for nx=True
         res = await cache.aset("test_key_nx", 1, timeout=2, nx=True)
         assert res is True
-        await asyncio.sleep(3)
+        await anyio.sleep(3)
         res = await cache.aget("test_key_nx")
         assert res is None
 
         # test that timeout will not affect key, if it was there
         await cache.aset("test_key_nx", 1)
         res = await cache.aset("test_key_nx", 2, timeout=2, nx=True)
         assert res is None
-        await asyncio.sleep(3)
+        await anyio.sleep(3)
         res = await cache.aget("test_key_nx")
         assert res == 1
 
@@ -152,7 +153,7 @@ async def test_save_float(self, cache: AsyncValkeyCache):
 
     async def test_timeout(self, cache: AsyncValkeyCache):
         await cache.aset("test_key", 222, timeout=3)
-        await asyncio.sleep(4)
+        await anyio.sleep(4)
 
         res = await cache.aget("test_key")
         assert res is None
@@ -171,7 +172,7 @@ async def test_timeout_parameter_as_positional_argument(
 
         await cache.aset("test_key", 222, 1)
         res1 = await cache.aget("test_key")
-        await asyncio.sleep(2)
+        await anyio.sleep(2)
         res2 = await cache.aget("test_key")
         assert res1 == 222
         assert res2 is None
@@ -732,7 +733,7 @@ async def test_lock_released_by_thread(self, cache: AsyncValkeyCache):
         async def release_lock(lock_):
             await lock_.release()
 
-        t = threading.Thread(target=asyncio.run, args=[release_lock(lock)])
+        t = threading.Thread(target=anyio.run, args=[release_lock, lock])
         t.start()
         t.join()
 
@@ -802,7 +803,7 @@ async def test_touch_positive_timeout(self, cache: AsyncValkeyCache):
 
         assert await cache.atouch("test_key", 2) is True
         assert await cache.aget("test_key") == 222
-        await asyncio.sleep(3)
+        await anyio.sleep(3)
         assert await cache.aget("test_key") is None
 
     async def test_touch_negative_timeout(self, cache: AsyncValkeyCache):
@@ -820,7 +821,7 @@ async def test_touch_forever(self, cache: AsyncValkeyCache):
         result = await cache.atouch("test_key", None)
         assert result is True
         assert await cache.attl("test_key") is None
-        await asyncio.sleep(2)
+        await anyio.sleep(2)
         assert await cache.aget("test_key") == "foo"
 
     async def test_touch_forever_nonexistent(self, cache: AsyncValkeyCache):
@@ -831,7 +832,7 @@ async def test_touch_default_timeout(self, cache: AsyncValkeyCache):
         await cache.aset("test_key", "foo", timeout=1)
         result = await cache.atouch("test_key")
         assert result is True
-        await asyncio.sleep(2)
+        await anyio.sleep(2)
         assert await cache.aget("test_key") == "foo"
 
     async def test_clear(self, cache: AsyncValkeyCache):