Add support for python 3.10 (#78)

* feat: lower minimum Python version to 3.10

Replace asyncio.TaskGroup (Python 3.11+) in tests/test_notifier.py with
asyncio.ensure_future and asyncio.gather, which are compatible with
Python 3.10. Update requires-python in pyproject.toml and add 3.10 to
the CI test matrix.

Co-authored-by: Cursor <cursoragent@cursor.com>

* ci: skip examples on 3.10 lane and harden test cleanup

- Lower examples/*/pyproject.toml requires-python to >=3.10 so the
  workspace lockfile resolves on 3.10 (uv unifies requires-python across
  workspace members; any member at >=3.11 forces the lock to refuse 3.10).
  Example sources still target 3.11+ at runtime; they are not installed
  or type-checked on the 3.10 CI lane.
- ci.yml: on the 3.10 matrix entry, sync without --all-packages and run
  pyright scoped to fishjam/ so the 3.11+ examples never reach the 3.10
  venv. 3.11+ lanes are unchanged.
- tests/test_notifier.py: wrap each async test in try/finally with
  asyncio.gather(*, return_exceptions=True) so background tasks are
  always cancelled and awaited, restoring the auto-cleanup semantics
  asyncio.TaskGroup provided. Replace the inconsistent
  try/except CancelledError pattern in two tests.
- uv.lock regenerated against the new workspace constraint.

* tests: replace asyncio.timeout(0) with await + suppress(CancelledError)

asyncio.timeout is 3.11+. After task.cancel(), awaiting the task raises
CancelledError once cancellation propagates; suppressing it is equivalent
to the previous TimeoutError-via-timeout(0) idiom and works on 3.10.

---------

Co-authored-by: flochtililoch <flochtililoch@gmail.com>
Co-authored-by: Cursor <cursoragent@cursor.com>

Author: 3 people

.github/workflows/ci.yml

@@ -24,7 +24,7 @@ jobs:
     runs-on: ubuntu-latest
     strategy: &strategy
       matrix:
-        python-version: ["3.11", "3.12", "3.13"]
+        python-version: ["3.10", "3.11", "3.12", "3.13"]
     steps:
       - uses: actions/checkout@v4
       - uses: astral-sh/setup-uv@v5
@@ -33,10 +33,20 @@ jobs:
           enable-cache: true
 
       - name: Install project dependencies
-        run: uv sync --locked --all-extras --all-packages
+        run: |
+          if [ "${{ matrix.python-version }}" = "3.10" ]; then
+            uv sync --locked --all-extras
+          else
+            uv sync --locked --all-extras --all-packages
+          fi
 
       - name: Type check
-        run: uv run pyright
+        run: |
+          if [ "${{ matrix.python-version }}" = "3.10" ]; then
+            uv run pyright fishjam
+          else
+            uv run pyright
+          fi
 
   test:
     runs-on: ubuntu-latest
@@ -50,7 +60,12 @@ jobs:
           enable-cache: true
 
       - name: Install project dependencies
-        run: uv sync --locked --all-extras --all-packages
+        run: |
+          if [ "${{ matrix.python-version }}" = "3.10" ]; then
+            uv sync --locked --all-extras
+          else
+            uv sync --locked --all-extras --all-packages
+          fi
 
       - name: Initialize Localtunnel
         id: tunnel

examples/multimodal/pyproject.toml

@@ -3,7 +3,7 @@ name = "multimodal"
 version = "0.1.0"
 description = "Fishjam multimodal demo with Gemini Live API"
 readme = "README.md"
-requires-python = ">=3.11"
+requires-python = ">=3.10"
 dependencies = [
     "fastapi[standard]==0.116.0",
     "fishjam-server-sdk",

examples/poet_chat/pyproject.toml

@@ -3,7 +3,7 @@ name = "poet_chat"
 version = "0.1.0"
 description = "Fishjam voice agent example"
 readme = "README.md"
-requires-python = ">=3.11"
+requires-python = ">=3.10"
 dependencies = ["fishjam-server-sdk", "openai-agents[voice]>=0.2.11"]
 
 [tool.uv.sources]

examples/selective_subscription/pyproject.toml

@@ -3,7 +3,7 @@ name = "selective-subscription-demo"
 version = "0.1.0"
 description = "Selective subscription demo using Fishjam Python SDK"
 readme = "README.md"
-requires-python = ">=3.11"
+requires-python = ">=3.10"
 dependencies = [
     "starlette>=0.35.0",
     "uvicorn>=0.25.0",

examples/transcription/pyproject.toml

@@ -3,7 +3,7 @@ name = "transcription"
 version = "0.1.0"
 description = "Fishjam transcription demo"
 readme = "README.md"
-requires-python = ">=3.11"
+requires-python = ">=3.10"
 dependencies = [
     "fastapi[standard]==0.116.0",
     "fishjam-server-sdk",

pyproject.toml

@@ -3,7 +3,7 @@ name = "fishjam-server-sdk"
 version = "0.26.0"
 description = "Python server SDK for the Fishjam"
 authors = [{ name = "Fishjam Team", email = "contact@fishjam.io" }]
-requires-python = ">=3.11"
+requires-python = ">=3.10"
 readme = "README.md"
 license = "Apache-2.0"
 dependencies = [

tests/agent/test_agent.py

@@ -54,9 +54,8 @@ def _(notification: AllowedNotification):
     yield notifier
 
     task.cancel()
-    with suppress(asyncio.TimeoutError):
-        async with asyncio.timeout(0):
-            await task
+    with suppress(asyncio.CancelledError):
+        await task
 
 
 class TestAgentApi:

tests/test_notifier.py

@@ -80,16 +80,17 @@ async def test_valid_credentials(self):
         def handle_notitifcation(_notification):
             pass
 
-        async with asyncio.TaskGroup() as tg:
-            notifier_task = tg.create_task(notifier.connect())
+        notifier_task = asyncio.ensure_future(notifier.connect())
+        try:
             await notifier.wait_ready()
 
             assert (
                 notifier._websocket
                 and notifier._websocket.state == websockets.State.OPEN
             )
-
+        finally:
             notifier_task.cancel()
+            await asyncio.gather(notifier_task, return_exceptions=True)
 
 
 @pytest.fixture
@@ -114,10 +115,11 @@ async def test_room_created_deleted(
     ):
         event_checks = [ServerMessageRoomCreated, ServerMessageRoomDeleted]
 
-        async with asyncio.TaskGroup() as tg:
-            assert_task = tg.create_task(assert_events(notifier, event_checks.copy()))
-
-            notifier_task = tg.create_task(notifier.connect())
+        assert_task = asyncio.ensure_future(
+            assert_events(notifier, event_checks.copy())
+        )
+        notifier_task = asyncio.ensure_future(notifier.connect())
+        try:
             await notifier.wait_ready()
 
             options = RoomOptions(webhook_url=WEBHOOK_URL)
@@ -126,8 +128,10 @@ async def test_room_created_deleted(
             room_api.delete_room(room.id)
 
             await assert_task
-
+        finally:
+            assert_task.cancel()
             notifier_task.cancel()
+            await asyncio.gather(assert_task, notifier_task, return_exceptions=True)
 
         self.assert_webhook_events(event_checks, event_queue, room.id)
 
@@ -144,28 +148,32 @@ async def test_peer_connected_disconnected(
             ServerMessageRoomDeleted,
         ]
 
-        async with asyncio.TaskGroup() as tg:
-            assert_task = tg.create_task(assert_events(notifier, event_checks.copy()))
-
-            notifier_task = tg.create_task(notifier.connect())
+        assert_task = asyncio.ensure_future(
+            assert_events(notifier, event_checks.copy())
+        )
+        notifier_task = asyncio.ensure_future(notifier.connect())
+        tasks = [assert_task, notifier_task]
+        try:
             await notifier.wait_ready()
 
             options = RoomOptions(webhook_url=WEBHOOK_URL)
             room = room_api.create_room(options=options)
 
             peer, token = room_api.create_peer(room.id)
             peer_socket = PeerSocket(fishjam_url=FISHJAM_ID)
-            peer_socket_task = tg.create_task(peer_socket.connect(token))
+            peer_socket_task = asyncio.ensure_future(peer_socket.connect(token))
+            tasks.append(peer_socket_task)
 
             await peer_socket.wait_ready()
 
             room_api.delete_peer(room.id, peer.id)
             room_api.delete_room(room.id)
 
             await assert_task
-
-            notifier_task.cancel()
-            peer_socket_task.cancel()
+        finally:
+            for task in tasks:
+                task.cancel()
+            await asyncio.gather(*tasks, return_exceptions=True)
 
         self.assert_webhook_events(event_checks, event_queue, room.id)
 
@@ -181,27 +189,31 @@ async def test_peer_connected_room_deleted(
             ServerMessageRoomDeleted,
         ]
 
-        async with asyncio.TaskGroup() as tg:
-            assert_task = tg.create_task(assert_events(notifier, event_checks.copy()))
-
-            notifier_task = tg.create_task(notifier.connect())
+        assert_task = asyncio.ensure_future(
+            assert_events(notifier, event_checks.copy())
+        )
+        notifier_task = asyncio.ensure_future(notifier.connect())
+        tasks = [assert_task, notifier_task]
+        try:
             await notifier.wait_ready()
 
             options = RoomOptions(webhook_url=WEBHOOK_URL)
             room = room_api.create_room(options=options)
             _peer, token = room_api.create_peer(room.id)
 
             peer_socket = PeerSocket(fishjam_url=FISHJAM_ID)
-            peer_socket_task = tg.create_task(peer_socket.connect(token))
+            peer_socket_task = asyncio.ensure_future(peer_socket.connect(token))
+            tasks.append(peer_socket_task)
 
             await peer_socket.wait_ready()
 
             room_api.delete_room(room.id)
 
             await assert_task
-
-            notifier_task.cancel()
-            peer_socket_task.cancel()
+        finally:
+            for task in tasks:
+                task.cancel()
+            await asyncio.gather(*tasks, return_exceptions=True)
 
         self.assert_webhook_events(event_checks, event_queue, room.id)