add support for 3.8 and 3.9

Author: RichardZhu2

.github/workflows/test.yml

@@ -15,6 +15,9 @@ jobs:
     strategy:
       matrix:
         python-version: [
+            3.8,
+            3.9,
+            3.10,
             3.11,
             3.12,
             3.13

pyproject.toml

@@ -9,7 +9,7 @@ name = "python-pyper"
 dynamic = ["version"]
 description = "Concurrent Python made simple"
 readme = "README.md"
-requires-python = ">=3.10"
+requires-python = ">=3.8"
 authors = [
     { name = "Richard Zhu", email = "[email protected]" },
 ]
@@ -23,11 +23,17 @@ classifiers = [
     "Framework :: AsyncIO",
     "License :: OSI Approved :: MIT License",
     "Programming Language :: Python :: 3 :: Only",
+    "Programming Language :: Python :: 3.8",
+    "Programming Language :: Python :: 3.9",
     "Programming Language :: Python :: 3.10",
     "Programming Language :: Python :: 3.11",
     "Programming Language :: Python :: 3.12",
     "Programming Language :: Python :: 3.13"
 ]
+dependencies = [
+    # Typing support dependency only for Python versions < 3.10
+    "typing_extensions; python_version<'3.10'"
+]
 
 [project.urls]
 Documentation = "https://pyper-dev.github.io/pyper/"

src/pyper/_core/decorators.py

@@ -1,13 +1,19 @@
 from __future__ import annotations
 
 import functools
+import sys
 import typing as t
 
 from .pipeline import AsyncPipeline, Pipeline
 from .task import Task
 
+if sys.version_info < (3, 10):  # pragma: no cover
+    from typing_extensions import ParamSpec
+else:
+    from typing import ParamSpec
 
-_P = t.ParamSpec('P')
+
+_P = ParamSpec('P')
 _R = t.TypeVar('R')
 _ArgsKwargs: t.TypeAlias = t.Optional[t.Tuple[t.Tuple[t.Any], t.Dict[str, t.Any]]]
 

src/pyper/_core/pipeline.py

@@ -1,18 +1,24 @@
 from __future__ import annotations
 
 import inspect
+import sys
 import typing as t
 
 from .async_helper.output import AsyncPipelineOutput
 from .sync_helper.output import PipelineOutput
 
+if sys.version_info < (3, 10):  # pragma: no cover
+    from typing_extensions import ParamSpec
+else:
+    from typing import ParamSpec
+
 if t.TYPE_CHECKING:
     from .task import Task
 
 
-_P = t.ParamSpec('P')
+_P = ParamSpec('P')
 _R = t.TypeVar('R')
-_P_Other = t.ParamSpec("P_Other")
+_P_Other = ParamSpec("P_Other")
 _R_Other = t.TypeVar("R_Other")
 
 
@@ -90,7 +96,7 @@ def __gt__(self, other: t.Callable[..., _R_Other]) -> t.Callable[_P, _R_Other]:
         return self.consume(other)
 
     def __repr__(self):
-        return f"{self.__class__.__name__} {[task.func for task in self.tasks]}"
+        return f"<{self.__class__.__name__} {[task.func for task in self.tasks]}>"
 
 
 class AsyncPipeline(Pipeline[_P, _R]):

tests/docker-compose.yaml

@@ -32,3 +32,19 @@ services:
       dockerfile: tests/Dockerfile
       args:
         PYTHON_VERSION: "3.10"
+
+  python3.9:
+    container_name: test3.9
+    build:
+      context: ..
+      dockerfile: tests/Dockerfile
+      args:
+        PYTHON_VERSION: "3.9"
+
+  python3.8:
+    container_name: test3.8
+    build:
+      context: ..
+      dockerfile: tests/Dockerfile
+      args:
+        PYTHON_VERSION: "3.8"