Add support to django 5.1

.github/workflows/ci.yml

@@ -20,6 +20,7 @@ jobs:
         django-version:
           - '4.2'
           - '5.0'
+          - '5.1'
         redis-version:
           - 'latest'
 
@@ -36,7 +37,7 @@ jobs:
             python-version: '3.9'
 
           # latest Django with pre-release redis
-          - django-version: '5.0'
+          - django-version: '5.1'
             redis-version: 'master'
             python-version: '3.11'
 

changelog.d/752.bugfix

@@ -0,0 +1 @@
+Added blocking parameter for `cache.lock`

changelog.d/754.misc

@@ -0,0 +1 @@
+Added support for django 5.1

django_redis/client/default.py

@@ -326,9 +326,7 @@ def expire(
 
         key = self.make_key(key, version=version)
 
-        # for some strange reason mypy complains,
-        # saying that timeout type is float | timedelta
-        return client.expire(key, timeout)  # type: ignore
+        return client.expire(key, timeout)
 
     def pexpire(
         self,
@@ -345,11 +343,7 @@ def pexpire(
 
         key = self.make_key(key, version=version)
 
-        # Temporary casting until https://github.com/redis/redis-py/issues/1664
-        # is fixed.
-        # for some strange reason mypy complains,
-        # saying that timeout type is float | timedelta
-        return bool(client.pexpire(key, timeout))  # type: ignore
+        return bool(client.pexpire(key, timeout))
 
     def pexpire_at(
         self,
@@ -393,6 +387,7 @@ def lock(
         version: Optional[int] = None,
         timeout: Optional[float] = None,
         sleep: float = 0.1,
+        blocking: bool = True,
         blocking_timeout: Optional[float] = None,
         client: Optional[Redis] = None,
         thread_local: bool = True,
@@ -405,6 +400,7 @@ def lock(
             key,
             timeout=timeout,
             sleep=sleep,
+            blocking=blocking,
             blocking_timeout=blocking_timeout,
             thread_local=thread_local,
         )

django_redis/client/herd.py

@@ -26,9 +26,7 @@ def _is_expired(x, herd_timeout: int) -> bool:
         return True
     val = x + random.randint(1, herd_timeout)
 
-    if val >= herd_timeout:
-        return True
-    return False
+    return val >= herd_timeout
 
 
 class HerdClient(DefaultClient):

setup.cfg

@@ -14,6 +14,7 @@ classifiers =
     Framework :: Django
     Framework :: Django :: 4.2
     Framework :: Django :: 5.0
+    Framework :: Django :: 5.1
     Intended Audience :: Developers
     License :: OSI Approved :: BSD License
     Operating System :: OS Independent
@@ -56,9 +57,9 @@ envlist =
     ruff
     mypy
     # tests against released versions
-    py{38,39,310,311}-dj{42,50}-redislatest
+    py{38,39,310,311}-dj{42,50,51}-redislatest
     # tests against unreleased versions
-    py311-dj50-redismaster
+    py311-dj51-redismaster
     py311-djmain-redis{latest,master}
 
 [gh-actions]
@@ -72,6 +73,7 @@ python =
 DJANGO =
     4.2: dj42
     5.0: dj50
+    5.1: dj51
     main: djmain
 REDIS =
     latest: redislatest
@@ -98,6 +100,7 @@ commands =
 deps =
     dj42: Django>=4.2,<5.0
     dj50: Django>=5.0,<5.1
+    dj51: Django>=5.1,<5.2
     djmain: https://github.com/django/django/archive/main.tar.gz
     msgpack>=0.6.0
     pytest

tests/test_backend.py

@@ -677,15 +677,27 @@
 
     def test_lock(self, cache: RedisCache):
         lock = cache.lock("foobar")
-        lock.acquire(blocking=True)
+        assert lock.acquire(blocking=True)
+
+        assert cache.has_key("foobar")
+        lock.release()
+        assert not cache.has_key("foobar")
+
+    def test_lock_not_blocking(self, cache: RedisCache):
+        lock = cache.lock("foobar")
+        assert lock.acquire(blocking=False)
+
+        lock2 = cache.lock("foobar")
+
+        assert not lock2.acquire(blocking=False)
 
         assert cache.has_key("foobar")
         lock.release()
         assert not cache.has_key("foobar")
 
     def test_lock_released_by_thread(self, cache: RedisCache):
         lock = cache.lock("foobar", thread_local=False)
-        lock.acquire(blocking=True)
+        assert lock.acquire(blocking=True)
 
         def release_lock(lock_):
             lock_.release()