Revert "Support Python 3.14 (#354)"

This reverts commit 2e3ba33.

Author: Kludex

.coveragerc

@@ -0,0 +1,5 @@
+[run]
+source =
+    mangum
+omit =
+    tests/*

.github/workflows/docs.yml

@@ -22,7 +22,7 @@ jobs:
       - name: Install uv
         uses: astral-sh/setup-uv@v2
         with:
-          version: "0.9.18"
+          version: "0.4.12"
           enable-cache: true
 
       - name: Set up Python

.github/workflows/main.yml

@@ -11,14 +11,14 @@ jobs:
     runs-on: ubuntu-latest
     strategy:
       matrix:
-        python-version: ["3.9", "3.10", "3.11", "3.12", "3.13", "3.14"]
+        python-version: ["3.9", "3.10", "3.11", "3.12", "3.13"]
     steps:
       - uses: actions/checkout@v4
 
       - name: Install uv
         uses: astral-sh/setup-uv@v2
         with:
-          version: "0.9.18"
+          version: "0.4.12"
           enable-cache: true
 
       - name: Set up Python ${{ matrix.python-version }}

.github/workflows/publish.yml

@@ -16,7 +16,7 @@ jobs:
       - name: Install uv
         uses: astral-sh/setup-uv@v2
         with:
-          version: "0.9.18"
+          version: "0.4.12"
           enable-cache: true
 
       - name: Set up Python

mangum/_compat.py

@@ -1,10 +1,10 @@
 from __future__ import annotations
 
 import logging
+from contextlib import ExitStack
 from itertools import chain
 from typing import Any
 
-from mangum._compat import asyncio_run
 from mangum.exceptions import ConfigurationError
 from mangum.handlers import ALB, APIGateway, HTTPGateway, LambdaAtEdge
 from mangum.protocols import HTTPCycle, LifespanCycle
@@ -59,20 +59,17 @@ def infer(self, event: LambdaEvent, context: LambdaContext) -> LambdaHandler:
         )
 
     def __call__(self, event: LambdaEvent, context: LambdaContext) -> dict[str, Any]:
-        async def handle_request() -> dict[str, Any]:
-            handler = self.infer(event, context)
-            scope = handler.scope
-
+        handler = self.infer(event, context)
+        scope = handler.scope
+        with ExitStack() as stack:
             if self.lifespan in ("auto", "on"):
                 lifespan_cycle = LifespanCycle(self.app, self.lifespan)
-                async with lifespan_cycle:
-                    scope.update({"state": lifespan_cycle.lifespan_state.copy()})
-                    http_cycle = HTTPCycle(scope, handler.body)
-                    http_response = await http_cycle(self.app)
-                    return handler(http_response)
-            else:
-                http_cycle = HTTPCycle(scope, handler.body)
-                http_response = await http_cycle(self.app)
-                return handler(http_response)
+                stack.enter_context(lifespan_cycle)
+                scope.update({"state": lifespan_cycle.lifespan_state.copy()})
+
+            http_cycle = HTTPCycle(scope, handler.body)
+            http_response = http_cycle(self.app)
+
+            return handler(http_response)
 
-        return asyncio_run(handle_request())
+        assert False, "unreachable"  # pragma: no cover

mangum/adapter.py

@@ -33,11 +33,25 @@ def __init__(self, scope: Scope, body: bytes) -> None:
         self.state = HTTPCycleState.REQUEST
         self.logger = logging.getLogger("mangum.http")
         self.app_queue: asyncio.Queue[Message] = asyncio.Queue()
-        self.app_queue.put_nowait({"type": "http.request", "body": body, "more_body": False})
+        self.app_queue.put_nowait(
+            {
+                "type": "http.request",
+                "body": body,
+                "more_body": False,
+            }
+        )
 
-    async def __call__(self, app: ASGI) -> Response:
-        await self.run(app)
-        return {"status": self.status, "headers": self.headers, "body": self.body}
+    def __call__(self, app: ASGI) -> Response:
+        asgi_instance = self.run(app)
+        loop = asyncio.get_event_loop()
+        asgi_task = loop.create_task(asgi_instance)
+        loop.run_until_complete(asgi_task)
+
+        return {
+            "status": self.status,
+            "headers": self.headers,
+            "body": self.body,
+        }
 
     async def run(self, app: ASGI) -> None:
         try:

mangum/protocols/http.py

@@ -59,26 +59,26 @@ def __init__(self, app: ASGI, lifespan: LifespanMode) -> None:
         self.lifespan = lifespan
         self.state: LifespanCycleState = LifespanCycleState.CONNECTING
         self.exception: BaseException | None = None
+        self.loop = asyncio.get_event_loop()
         self.app_queue: asyncio.Queue[Message] = asyncio.Queue()
         self.startup_event: asyncio.Event = asyncio.Event()
         self.shutdown_event: asyncio.Event = asyncio.Event()
         self.logger = logging.getLogger("mangum.lifespan")
         self.lifespan_state: dict[str, Any] = {}
 
-    async def __aenter__(self) -> LifespanCycle:
+    def __enter__(self) -> None:
         """Runs the event loop for application startup."""
-        asyncio.create_task(self.run())
-        await self.startup()
-        return self
+        self.loop.create_task(self.run())
+        self.loop.run_until_complete(self.startup())
 
-    async def __aexit__(
+    def __exit__(
         self,
         exc_type: type[BaseException] | None,
         exc_value: BaseException | None,
         traceback: TracebackType | None,
     ) -> None:
         """Runs the event loop for application shutdown."""
-        await self.shutdown()
+        self.loop.run_until_complete(self.shutdown())
 
     async def run(self) -> None:
         """Calls the application with the `lifespan` connection scope."""

mangum/protocols/lifespan.py

@@ -21,21 +21,17 @@ classifiers = [
     "Programming Language :: Python :: 3.11",
     "Programming Language :: Python :: 3.12",
     "Programming Language :: Python :: 3.13",
-    "Programming Language :: Python :: 3.14",
     "Topic :: Internet :: WWW/HTTP",
 ]
 dependencies = ["typing_extensions"]
 
-[tool.uv]
-default-groups = ["dev"]
-
 [dependency-groups]
 dev = [
-    "pytest>=8.0.0",
-    "coverage",
+    "pytest",
+    "pytest-cov",
     "ruff",
     "starlette",
-    "quart>=0.20.0",
+    "quart",
     "hypercorn>=0.15.0",
     "mypy",
     "brotli",
@@ -70,6 +66,10 @@ ignore = ["UP031"] # https://docs.astral.sh/ruff/rules/printf-string-formatting/
 strict = true
 
 [tool.pytest.ini_options]
+log_cli = true
+log_cli_level = "INFO"
+log_cli_format = "%(asctime)s [%(levelname)8s] %(message)s (%(filename)s:%(lineno)s)"
+log_cli_date_format = "%Y-%m-%d %H:%M:%S"
 addopts = "-rXs --strict-config --strict-markers"
 xfail_strict = true
 filterwarnings = [
@@ -86,12 +86,8 @@ filterwarnings = [
 
 [tool.coverage.run]
 source_pkgs = ["mangum", "tests"]
-omit = ["mangum/_compat.py"]
 
 [tool.coverage.report]
-fail_under = 100
-skip_covered = true
-show_missing = true
 exclude_lines = [
     "pragma: no cover",
     "pragma: nocover",

pyproject.toml

@@ -2,5 +2,4 @@
 
 set -x # print executed commands to the terminal
 
-uv run coverage run -m pytest "${@}"
-uv run coverage report
+uv run pytest --ignore venv --cov=mangum --cov=tests --cov-fail-under=100 --cov-report=term-missing "${@}"