♻️ Fixing typing for versions older than 3.10

flama/background.py

@@ -10,11 +10,11 @@
 if sys.version_info < (3, 10):  # PORT: Remove when stop supporting 3.9 # pragma: no cover
     from typing_extensions import ParamSpec
 
-    t.ParamSpec = ParamSpec
+    t.ParamSpec = ParamSpec  # type: ignore
 
 __all__ = ["BackgroundTask", "BackgroundTasks", "Concurrency", "BackgroundThreadTask", "BackgroundProcessTask"]
 
-P = t.ParamSpec("P")
+P = t.ParamSpec("P")  # type: ignore # PORT: Remove this comment when stop supporting 3.9
 
 
 class task_wrapper:

flama/concurrency.py

@@ -4,19 +4,33 @@
 import sys
 import typing as t
 
+if sys.version_info < (3, 9):  # PORT: Remove when stop supporting 3.8 # pragma: no cover
+    import contextvars
+
+    async def to_thread(func, /, *args, **kwargs):
+        return await asyncio.get_running_loop().run_in_executor(
+            None, functools.partial(contextvars.copy_context().run, func, *args, **kwargs)
+        )
+
+    asyncio.to_thread = to_thread  # pyright: ignore
+
 if sys.version_info < (3, 10):  # PORT: Remove when stop supporting 3.9 # pragma: no cover
     from typing_extensions import ParamSpec, TypeGuard
 
-    t.TypeGuard = TypeGuard
-    t.ParamSpec = ParamSpec
+    t.TypeGuard = TypeGuard  # type: ignore
+    t.ParamSpec = ParamSpec  # type: ignore
 
 __all__ = ["is_async", "run", "run"]
 
 R = t.TypeVar("R", covariant=True)
-P = t.ParamSpec("P")
+P = t.ParamSpec("P")  # type: ignore # PORT: Remove this comment when stop supporting 3.9
 
 
-def is_async(obj: t.Any) -> t.TypeGuard[t.Callable[..., t.Awaitable[t.Any]]]:
+def is_async(
+    obj: t.Any,
+) -> t.TypeGuard[  # type: ignore # PORT: Remove this comment when stop supporting 3.9
+    t.Callable[..., t.Awaitable[t.Any]]
+]:
     """Check if given object is an async function, callable or partialised function.
 
     :param obj: Object to check.

flama/routing.py

@@ -13,7 +13,7 @@
 if sys.version_info < (3, 10):  # PORT: Remove when stop supporting 3.9 # pragma: no cover
     from typing_extensions import TypeGuard
 
-    t.TypeGuard = TypeGuard
+    t.TypeGuard = TypeGuard  # type: ignore
 
 if t.TYPE_CHECKING:
     from flama.applications import Flama
@@ -336,7 +336,9 @@ def __repr__(self) -> str:
     @staticmethod
     def is_endpoint(
         x: t.Union[t.Callable, t.Type[endpoints.HTTPEndpoint]]
-    ) -> t.TypeGuard[t.Type[endpoints.HTTPEndpoint]]:
+    ) -> t.TypeGuard[  # type: ignore # PORT: Remove this comment when stop supporting 3.9
+        t.Type[endpoints.HTTPEndpoint]
+    ]:
         return inspect.isclass(x) and issubclass(x, endpoints.HTTPEndpoint)
 
     def endpoint_handlers(self) -> t.Dict[str, t.Callable]:
@@ -412,7 +414,9 @@ def __eq__(self, other: t.Any) -> bool:
     @staticmethod
     def is_endpoint(
         x: t.Union[t.Callable, t.Type[endpoints.WebSocketEndpoint]]
-    ) -> t.TypeGuard[t.Type[endpoints.WebSocketEndpoint]]:
+    ) -> t.TypeGuard[  # type: ignore # PORT: Remove this comment when stop supporting 3.9
+        t.Type[endpoints.WebSocketEndpoint]
+    ]:
         return inspect.isclass(x) and issubclass(x, endpoints.WebSocketEndpoint)
 
     def endpoint_handlers(self) -> t.Dict[str, t.Callable]:

flama/schemas/_libs/marshmallow/adapter.py

@@ -15,7 +15,7 @@
 if sys.version_info < (3, 10):  # PORT: Remove when stop supporting 3.9 # pragma: no cover
     from typing_extensions import TypeGuard
 
-    t.TypeGuard = TypeGuard
+    t.TypeGuard = TypeGuard  # type: ignore
 
 if t.TYPE_CHECKING:
     from apispec.ext.marshmallow import OpenAPIConverter
@@ -115,10 +115,18 @@ def unique_schema(self, schema: t.Union[Schema, t.Type[Schema]]) -> t.Type[Schem
 
         return schema
 
-    def is_schema(self, obj: t.Any) -> t.TypeGuard[t.Union[Schema, t.Type[Schema]]]:
+    def is_schema(
+        self, obj: t.Any
+    ) -> t.TypeGuard[  # type: ignore # PORT: Remove this comment when stop supporting 3.9
+        t.Union[Schema, t.Type[Schema]]
+    ]:
         return isinstance(obj, Schema) or (inspect.isclass(obj) and issubclass(obj, Schema))
 
-    def is_field(self, obj: t.Any) -> t.TypeGuard[t.Union[Field, t.Type[Field]]]:
+    def is_field(
+        self, obj: t.Any
+    ) -> t.TypeGuard[  # type: ignore # PORT: Remove this comment when stop supporting 3.9
+        t.Union[Field, t.Type[Field]]
+    ]:
         return isinstance(obj, Field) or (inspect.isclass(obj) and issubclass(obj, Field))
 
     def _schema_instance(self, schema: t.Union[t.Type[Schema], Schema]) -> Schema:

flama/schemas/_libs/pydantic/adapter.py

@@ -14,7 +14,7 @@
 if sys.version_info < (3, 10):  # PORT: Remove when stop supporting 3.9 # pragma: no cover
     from typing_extensions import TypeGuard
 
-    t.TypeGuard = TypeGuard
+    t.TypeGuard = TypeGuard  # type: ignore
 
 __all__ = ["PydanticAdapter"]
 
@@ -116,8 +116,12 @@ def to_json_schema(self, schema: t.Union[Schema, t.Type[Schema], Field]) -> JSON
     def unique_schema(self, schema: t.Union[Schema, t.Type[Schema]]) -> t.Type[Schema]:
         return schema.__class__ if isinstance(schema, Schema) else schema
 
-    def is_schema(self, obj: t.Any) -> t.TypeGuard[t.Type[Schema]]:
+    def is_schema(
+        self, obj: t.Any
+    ) -> t.TypeGuard[t.Type[Schema]]:  # type: ignore # PORT: Remove this comment when stop supporting 3.9
         return inspect.isclass(obj) and issubclass(obj, Schema)
 
-    def is_field(self, obj: t.Any) -> t.TypeGuard[Field]:
+    def is_field(
+        self, obj: t.Any
+    ) -> t.TypeGuard[Field]:  # type: ignore # PORT: Remove this comment when stop supporting 3.9
         return isinstance(obj, Field)

flama/schemas/_libs/typesystem/adapter.py

@@ -13,7 +13,7 @@
 if sys.version_info < (3, 10):  # PORT: Remove when stop supporting 3.9 # pragma: no cover
     from typing_extensions import TypeGuard
 
-    t.TypeGuard = TypeGuard
+    t.TypeGuard = TypeGuard  # type: ignore
 
 __all__ = ["TypesystemAdapter"]
 
@@ -101,9 +101,13 @@ def unique_schema(self, schema: Schema) -> Schema:
         return schema
 
     @t.no_type_check
-    def is_schema(self, obj: t.Any) -> t.TypeGuard[Schema]:
+    def is_schema(
+        self, obj: t.Any
+    ) -> t.TypeGuard[Schema]:  # type: ignore # PORT: Remove this comment when stop supporting 3.9
         return isinstance(obj, Schema) or (inspect.isclass(obj) and issubclass(obj, Schema))
 
     @t.no_type_check
-    def is_field(self, obj: t.Any) -> t.TypeGuard[Field]:
+    def is_field(
+        self, obj: t.Any
+    ) -> t.TypeGuard[Field]:  # type: ignore # PORT: Remove this comment when stop supporting 3.9
         return isinstance(obj, Field) or (inspect.isclass(obj) and issubclass(obj, Field))

flama/schemas/adapter.py

@@ -8,7 +8,7 @@
 if sys.version_info < (3, 10):  # PORT: Remove when stop supporting 3.9 # pragma: no cover
     from typing_extensions import TypeGuard
 
-    t.TypeGuard = TypeGuard
+    t.TypeGuard = TypeGuard  # type: ignore
 
 
 class Adapter(t.Generic[_T_Schema, _T_Field], metaclass=abc.ABCMeta):
@@ -83,9 +83,17 @@ def unique_schema(self, schema: t.Union[_T_Schema, t.Type[_T_Schema]]) -> t.Unio
         ...
 
     @abc.abstractmethod
-    def is_schema(self, obj: t.Any) -> t.TypeGuard[t.Union[_T_Schema, t.Type[_T_Schema]]]:
+    def is_schema(
+        self, obj: t.Any
+    ) -> t.TypeGuard[  # type: ignore # PORT: Remove this comment when stop supporting 3.9
+        t.Union[_T_Schema, t.Type[_T_Schema]]
+    ]:
         ...
 
     @abc.abstractmethod
-    def is_field(self, obj: t.Any) -> t.TypeGuard[t.Union[_T_Field, t.Type[_T_Field]]]:
+    def is_field(
+        self, obj: t.Any
+    ) -> t.TypeGuard[  # type: ignore # PORT: Remove this comment when stop supporting 3.9
+        t.Union[_T_Field, t.Type[_T_Field]]
+    ]:
         ...

flama/schemas/data_structures.py

@@ -10,7 +10,7 @@
 if sys.version_info < (3, 10):  # PORT: Remove when stop supporting 3.9 # pragma: no cover
     from typing_extensions import TypeGuard
 
-    t.TypeGuard = TypeGuard
+    t.TypeGuard = TypeGuard  # type: ignore
 
 __all__ = ["Field", "Schema", "Parameter", "Parameters"]
 

flama/types/asgi.py

@@ -4,8 +4,8 @@
 if sys.version_info < (3, 10):  # PORT: Remove when stop supporting 3.9 # pragma: no cover
     from typing_extensions import Concatenate, ParamSpec
 
-    t.Concatenate = Concatenate
-    t.ParamSpec = ParamSpec
+    t.Concatenate = Concatenate  # type: ignore
+    t.ParamSpec = ParamSpec  # type: ignore
 
 if t.TYPE_CHECKING:
     from flama import endpoints  # noqa
@@ -29,7 +29,7 @@
     "WebSocketHandler",
 ]
 
-P = t.ParamSpec("P")
+P = t.ParamSpec("P")  # type: ignore # PORT: Remove this comment when stop supporting 3.9
 R = t.TypeVar("R", covariant=True)
 
 Scope = t.NewType("Scope", t.MutableMapping[str, t.Any])
@@ -73,8 +73,12 @@ def __init__(self, app: App, *args: P.args, **kwargs: P.kwargs):
         ...
 
 
-MiddlewareFunction = t.Callable[t.Concatenate[App, P], App]
-MiddlewareAsyncFunction = t.Callable[t.Concatenate[App, P], t.Awaitable[App]]
+MiddlewareFunction = t.Callable[
+    t.Concatenate[App, P], App  # type: ignore # PORT: Remove this comment when stop supporting 3.9
+]
+MiddlewareAsyncFunction = t.Callable[
+    t.Concatenate[App, P], t.Awaitable[App]  # type: ignore # PORT: Remove this comment when stop supporting 3.9
+]
 Middleware = t.Union[t.Type[MiddlewareClass], t.Type[MiddlewareAsyncClass], MiddlewareFunction, MiddlewareAsyncFunction]
 
 HTTPHandler = t.Union[AppFunction, t.Type["endpoints.HTTPEndpoint"]]

flama/types/schema.py

@@ -5,15 +5,17 @@
 if sys.version_info < (3, 10):  # PORT: Remove when stop supporting 3.9 # pragma: no cover
     from typing_extensions import TypeGuard
 
-    t.TypeGuard = TypeGuard
+    t.TypeGuard = TypeGuard  # type: ignore
 
 __all__ = ["Schema", "is_schema"]
 
 _T_Field = t.TypeVar("_T_Field")
 _T_Schema = t.TypeVar("_T_Schema")
 
 
-def is_schema(obj: t.Any) -> t.TypeGuard[t.Type["Schema"]]:
+def is_schema(
+    obj: t.Any,
+) -> t.TypeGuard[t.Type["Schema"]]:  # type: ignore # PORT: Remove this comment when stop supporting 3.9
     return inspect.isclass(obj) and issubclass(obj, Schema)