request handler validation fix

basis-company · Sep 23, 2023 · 74c6384 · 74c6384
1 parent c45284d
commit 74c6384
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/sharded_queue/__init__.py b/sharded_queue/__init__.py
@@ -28,10 +28,10 @@ async def create(cls) -> Self:
 
     @classmethod
     def request_cls(cls) -> type[T]:
-        cls = list(get_type_hints(cls.handle).values())[0]
-        if cls is T:
+        request_cls = list(get_type_hints(cls.handle).values())[0]
+        if isinstance(request_cls, TypeVar):
             raise NotImplementedError
-        return cls
+        return request_cls
 
     @classmethod
     async def route(cls, *requests: T) -> list[Route]: