fix: redis cache

Author: 1PaCHeK1

dynamic_expressions/cache/base.py

@@ -43,14 +43,16 @@ async def on_visit(
         key = policy.key(node, provided_context)
         serializer = policy.serializer or self.default_serializer
         cached_value = await self.get_cache(key)
+        deserialized_value: object | None = None
         if cached_value is not None:
-            execution_context.cache[node] = serializer.deserialize(cached_value)
+            deserialized_value = serializer.deserialize(cached_value)
+            execution_context.cache[node] = deserialized_value
 
         yield
 
         if (
             node in execution_context.cache
-            and cached_value != execution_context.cache[node]
+            and deserialized_value != execution_context.cache[node]
         ):
             await self.set_cache(
                 key=key,

dynamic_expressions/cache/redis.py

@@ -1,21 +1,23 @@
 from collections.abc import Sequence
-from typing import TYPE_CHECKING, Any
-
-from redis.asyncio import Redis
+from datetime import timedelta
+from typing import Any, Protocol
 
 from dynamic_expressions.cache.base import CacheExtension, CachePolicy
 from dynamic_expressions.serialization import Serializer
 from dynamic_expressions.types import EmptyContext
 
-if TYPE_CHECKING:
-    RedisClient = Redis[bytes]
-else:
-    RedisClient = Redis
+
+class RedisClient(Protocol):
+    async def get(self, name: str) -> bytes | None: ...
+    async def set(
+        self,
+        name: str,
+        value: bytes,
+        ex: timedelta | int,
+    ) -> None: ...
 
 
-class RedisCacheExtension[
-    Context: EmptyContext,
-](CacheExtension[Context]):
+class RedisCacheExtension[Context: EmptyContext](CacheExtension[Context]):
     def __init__(
         self,
         client: RedisClient,

pyproject.toml

@@ -62,7 +62,7 @@ exclude_lines = [
 
 [tool.deptry]
 [tool.deptry.per_rule_ignores]
-DEP002 = []
+DEP002 = ["redis"]
 
 [tool.mypy]
 plugins = [