serializer protocol fix

sharded_queue/drivers.py

@@ -1,24 +1,22 @@
 from json import dumps, loads
-from typing import Any, List, Sequence, TypeVar
+from typing import Any, List, Sequence
 
 from redis.asyncio import Redis
 
 from sharded_queue.protocols import Lock, Serializer, Storage
 from sharded_queue.settings import settings
 
-T = TypeVar('T')
-
 
 class JsonTupleSerializer(Serializer):
     def get_values(self, request) -> list[Any]:
         if isinstance(request, Sequence):
             return [k for k in request]
         return list(request.__dict__.values())
 
-    def serialize(self, request: T) -> str:
+    def serialize(self, request: Any) -> str:
         return dumps(self.get_values(request))
 
-    def deserialize(self, cls: type[T], source: str) -> T:
+    def deserialize(self, cls: type[Any], source: str) -> Any:
         values = loads(source)
         if hasattr(cls, 'model_fields'):
             return cls(**dict(zip(cls.model_fields, values)))

sharded_queue/protocols.py

@@ -1,6 +1,4 @@
-from typing import Any, Protocol, TypeVar
-
-T = TypeVar('T')
+from typing import Any, Protocol
 
 
 class Lock(Protocol):
@@ -10,10 +8,10 @@ async def release(self, key: str) -> None: ...
     async def ttl(self, key: str, ttl: int) -> bool: ...
 
 
-class Serializer(Protocol[T]):
+class Serializer(Protocol):
     def get_values(self, request) -> list[Any]: ...
-    def serialize(self, request: T) -> str: ...
-    def deserialize(self, cls: type[T], source: str) -> T: ...
+    def serialize(self, request: Any) -> str: ...
+    def deserialize(self, cls: type[Any], source: str) -> Any: ...
 
 
 class Storage(Protocol):