feat: add support for Python 3.13

.github/workflows/ci.yml

@@ -96,7 +96,7 @@ jobs:
     strategy:
       fail-fast: true
       matrix:
-        python-version: ["3.8", "3.9", "3.10", "3.11", "3.12"]
+        python-version: ["3.8", "3.9", "3.10", "3.11", "3.12", "3.13"]
     uses: ./.github/workflows/test.yml
     with:
       coverage: ${{ (matrix.python-version == '3.12' || matrix.python-version == '3.8') }}
@@ -123,6 +123,9 @@ jobs:
           version: "0.5.4"
           enable-cache: true
 
+      - name: Install Build Dependencies
+        run: sudo apt-get install build-essential libpq-dev python3-dev -y
+
       - name: Install dependencies
         run: |
           uv sync
@@ -190,6 +193,9 @@ jobs:
       - name: Check out repository
         uses: actions/checkout@v4
 
+      - name: Install Build Dependencies
+        run: sudo apt-get install build-essential libpq-dev python3-dev -y
+
       - name: Set up Python
         uses: actions/setup-python@v5
         with:
@@ -260,6 +266,9 @@ jobs:
       - name: Check out repository
         uses: actions/checkout@v4
 
+      - name: Install Build Dependencies
+        run: sudo apt-get install build-essential libpq-dev python3-dev -y
+
       - name: Set up Python
         uses: actions/setup-python@v5
         with:

.github/workflows/test.yml

@@ -38,6 +38,9 @@ jobs:
         with:
           python-version: ${{ inputs.python-version }}
 
+      - name: Install Build Dependencies
+        run: sudo apt-get install build-essential libpq-dev python3-dev -y
+
       - name: Install uv
         uses: astral-sh/setup-uv@v5
         with:

.pre-commit-config.yaml

@@ -1,5 +1,5 @@
 default_language_version:
-  python: "3"
+  python: "3.12"
 repos:
   - repo: https://github.com/compilerla/conventional-pre-commit
     rev: v3.6.0

litestar/channels/backends/psycopg.py

@@ -40,6 +40,7 @@ async def unsubscribe(self, channels: Iterable[str]) -> None:
         for channel in channels:
             await self._listener_conn.execute(SQL("UNLISTEN {channel}").format(channel=Identifier(channel)))
             await self._listener_conn.commit()
+
         self._subscribed_channels = self._subscribed_channels - set(channels)
 
     async def stream_events(self) -> AsyncGenerator[tuple[str, bytes], None]:

pyproject.toml

@@ -17,6 +17,7 @@ classifiers = [
   "Programming Language :: Python :: 3.10",
   "Programming Language :: Python :: 3.11",
   "Programming Language :: Python :: 3.12",
+  "Programming Language :: Python :: 3.13",
   "Programming Language :: Python",
   "Topic :: Internet :: WWW/HTTP",
   "Topic :: Software Development :: Libraries",
@@ -46,7 +47,7 @@ dependencies = [
   "rich-click",
   "multipart>=1.2.0",
   # default litestar plugins
-    "litestar-htmx>=0.4.0"
+  "litestar-htmx>=0.4.0"
 ]
 description = "Litestar - A production-ready, highly performant, extensible ASGI API Framework"
 keywords = ["api", "rest", "asgi", "litestar", "starlite"]
@@ -83,7 +84,8 @@ brotli = ["brotli"]
 cli = ["jsbeautifier", "uvicorn[standard]", "uvloop>=0.18.0; sys_platform != 'win32'"]
 cryptography = ["cryptography"]
 full = [
-  "litestar[annotated-types,attrs,brotli,cli,cryptography,jinja,jwt,mako,minijinja,opentelemetry,piccolo,picologging,prometheus,pydantic,redis,sqlalchemy,standard,structlog,valkey]",
+  "litestar[annotated-types,attrs,brotli,cli,cryptography,jinja,jwt,mako,minijinja,opentelemetry,piccolo,picologging,prometheus,pydantic,redis,sqlalchemy,standard,structlog,valkey]; python_version < \"3.13\"",
+  "litestar[annotated-types,attrs,brotli,cli,cryptography,jinja,jwt,mako,minijinja,opentelemetry,piccolo,prometheus,pydantic,redis,sqlalchemy,standard,structlog,valkey]; python_version >= \"3.13\"",
 ]
 jinja = ["jinja2>=3.1.2"]
 jwt = [
@@ -94,9 +96,14 @@ mako = ["mako>=1.2.4"]
 minijinja = ["minijinja>=1.0.0"]
 opentelemetry = ["opentelemetry-instrumentation-asgi"]
 piccolo = ["piccolo"]
-picologging = ["picologging"]
+picologging = ["picologging; python_version < \"3.13\""]
 prometheus = ["prometheus-client"]
-pydantic = ["pydantic", "email-validator", "pydantic-extra-types"]
+pydantic = [
+  "pydantic",
+  "email-validator",
+  "pydantic-extra-types!=2.9.0; python_version < \"3.9\"",
+  "pydantic-extra-types; python_version >= \"3.9\"",
+]
 redis = ["redis[hiredis]>=4.4.4"]
 valkey = ["valkey[libvalkey]>=6.0.2"]
 sqlalchemy = ["advanced-alchemy>=0.2.2"]
@@ -130,7 +137,8 @@ dev = [
   "trio",
   "aiosqlite",
   "asyncpg>=0.29.0",
-  "psycopg[pool,binary]>=3.1.10,<3.2",
+  "psycopg[pool,binary]>=3.1.10,<3.2; python_version < \"3.13\"",
+  "psycopg[pool,c]; python_version >= \"3.13\"",
   "psycopg2-binary",
   "psutil>=5.9.8",
   "hypercorn>=0.16.0",
@@ -167,7 +175,8 @@ linting = [
 test = [
   "covdefaults",
   "pytest",
-  "pytest-asyncio",
+  "pytest-asyncio; python_version < \"3.13\"",
+  "pytest-asyncio @ git+https://github.com/provinzkraut/pytest-asyncio.git@shutdown-asyncgens; python_version >= \"3.13\"",
   "pytest-cov",
   "pytest-lazy-fixtures",
   "pytest-mock",
@@ -285,6 +294,8 @@ module = [
   "pytimeparse.*",
   "importlib_resources",
   "exceptiongroup",
+  "picologging",
+  "picologging.*",
 ]
 
 [[tool.mypy.overrides]]

tests/unit/test_channels/test_plugin.py

@@ -170,7 +170,7 @@ def test_create_ws_route_handlers_arbitrary_channels_allowed(channels_backend: C
             channels_plugin.publish("something", "foo")
             assert ws.receive_text(timeout=2) == "something"
 
-        time.sleep(0.1)
+        time.sleep(0.4)
 
         with client.websocket_connect("/ws/bar") as ws:
             channels_plugin.publish("something else", "bar")

tests/unit/test_kwargs/test_validations.py

@@ -46,19 +46,19 @@ def handler(my_key: str = Parameter(**{param_field: "my_key"})) -> None:  # type
 @pytest.mark.parametrize("reserved_kwarg", sorted(RESERVED_KWARGS))
 def test_raises_when_reserved_kwargs_are_misused(reserved_kwarg: str) -> None:
     decorator = post if reserved_kwarg != "socket" else websocket
-
-    exec(f"async def test_fn({reserved_kwarg}: int) -> None: pass")
-    handler_with_path_param = decorator("/{" + reserved_kwarg + ":int}")(locals()["test_fn"])
+    local = dict(locals(), **globals())
+    exec(f"async def test_fn({reserved_kwarg}: int) -> None: pass", local, local)
+    handler_with_path_param = decorator("/{" + reserved_kwarg + ":int}")(local["test_fn"])
     with pytest.raises(ImproperlyConfiguredException):
         Litestar(route_handlers=[handler_with_path_param])
 
-    exec(f"async def test_fn({reserved_kwarg}: int) -> None: pass")
-    handler_with_dependency = decorator("/", dependencies={reserved_kwarg: Provide(my_dependency)})(locals()["test_fn"])
+    exec(f"async def test_fn({reserved_kwarg}: int) -> None: pass", local, local)
+    handler_with_dependency = decorator("/", dependencies={reserved_kwarg: Provide(my_dependency)})(local["test_fn"])
     with pytest.raises(ImproperlyConfiguredException):
         Litestar(route_handlers=[handler_with_dependency])
 
-    exec(f"async def test_fn({reserved_kwarg}: int = Parameter(query='my_param')) -> None: pass")
-    handler_with_aliased_param = decorator("/")(locals()["test_fn"])
+    exec(f"async def test_fn({reserved_kwarg}: int = Parameter(query='my_param')) -> None: pass", local, local)
+    handler_with_aliased_param = decorator("/")(local["test_fn"])
     with pytest.raises(ImproperlyConfiguredException):
         Litestar(route_handlers=[handler_with_aliased_param])
 

tests/unit/test_middleware/test_middleware_handling.py

@@ -1,8 +1,11 @@
 import logging
+import sys
 from dataclasses import dataclass
 from typing import TYPE_CHECKING, Any, Awaitable, Callable, List, cast
 
 import pytest
+from _pytest.capture import CaptureFixture
+from _pytest.logging import LogCaptureFixture
 from starlette.middleware.base import BaseHTTPMiddleware, RequestResponseEndpoint
 
 from litestar import Controller, Request, Response, Router, get, post
@@ -13,8 +16,6 @@
 if TYPE_CHECKING:
     from typing import Type
 
-    from _pytest.logging import LogCaptureFixture
-
     from litestar.types import ASGIApp, Receive, Scope, Send
 
 logger = logging.getLogger(__name__)
@@ -91,7 +92,7 @@ def handler() -> None: ...
             assert middleware_instance.arg == 1
 
 
-def test_request_body_logging_middleware(caplog: "LogCaptureFixture") -> None:
+def test_request_body_logging_middleware(caplog: LogCaptureFixture, capsys: "CaptureFixture[str]") -> None:
     @dataclass
     class JSONRequest:
         name: str
@@ -102,13 +103,22 @@ class JSONRequest:
     def post_handler(data: JSONRequest) -> JSONRequest:
         return data
 
-    with caplog.at_level(logging.INFO):
+    if sys.version_info < (3, 13):
+        with caplog.at_level(logging.INFO):
+            client = create_test_client(
+                route_handlers=[post_handler], middleware=[MiddlewareProtocolRequestLoggingMiddleware]
+            )
+            response = client.post("/", json={"name": "moishe zuchmir", "age": 40, "programmer": True})
+            assert response.status_code == 201
+            assert "test logging" in caplog.text
+    else:
         client = create_test_client(
             route_handlers=[post_handler], middleware=[MiddlewareProtocolRequestLoggingMiddleware]
         )
         response = client.post("/", json={"name": "moishe zuchmir", "age": 40, "programmer": True})
         assert response.status_code == 201
-        assert "test logging" in caplog.text
+        log = capsys.readouterr()
+        assert "test logging" in log.err
 
 
 def test_middleware_call_order() -> None: