chore(tests): increase speed by running tests in parallel

Author: alukach

.github/workflows/cicd.yaml

@@ -28,4 +28,4 @@ jobs:
       - uses: astral-sh/setup-uv@v4
         with:
           enable-cache: true
-      - run: uv run pytest
+      - run: uv run pytest -n auto

.vscode/settings.json

@@ -1,6 +1,8 @@
 {
   "python.testing.pytestArgs": [
-    "tests"
+    "tests",
+    "-n",
+    "auto"
   ],
   "python.testing.unittestEnabled": false,
   "python.testing.pytestEnabled": true

pyproject.toml

@@ -45,6 +45,7 @@ dev = [
   "pre-commit>=3.5.0",
   "pytest-asyncio>=0.25.1",
   "pytest-cov>=5.0.0",
+  "pytest-xdist>=3.6.1",
   "pytest>=8.3.3",
   "starlette-cramjam>=0.4.0",
 ]

tests/conftest.py

@@ -1,6 +1,7 @@
 """Pytest fixtures."""
 
 import os
+import socket
 import threading
 from typing import Any, AsyncGenerator
 from unittest.mock import DEFAULT, AsyncMock, MagicMock, patch
@@ -118,22 +119,35 @@ def source_api():
     return app
 
 
-@pytest.fixture(scope="session")
+@pytest.fixture()
 def source_api_server(source_api):
     """Run the source API in a background thread."""
-    host, port = "127.0.0.1", 9119
-    server = uvicorn.Server(
-        uvicorn.Config(
-            source_api,
-            host=host,
-            port=port,
+    sock = socket.socket()
+    try:
+        sock.bind(("", 0))
+        port = sock.getsockname()[1]
+        host = "127.0.0.1"
+        server = uvicorn.Server(
+            uvicorn.Config(
+                source_api,
+                host=host,
+                port=port,
+            )
         )
-    )
-    thread = threading.Thread(target=server.run)
-    thread.start()
-    yield f"http://{host}:{port}"
-    server.should_exit = True
-    thread.join()
+        thread = threading.Thread(target=server.run)
+        thread.daemon = True  # Make thread daemon so it exits when main thread exits
+        thread.start()
+
+        # Give the server a moment to start
+        import time
+
+        time.sleep(0.1)
+
+        yield f"http://{host}:{port}"
+    finally:
+        server.should_exit = True
+        thread.join(timeout=1.0)  # Add timeout to prevent hanging
+        sock.close()
 
 
 @pytest.fixture(autouse=True, scope="session")