Merge branch 'main' into add-dapr-session

Author: filintod

.github/workflows/tests.yml

@@ -41,6 +41,16 @@ jobs:
 
   tests:
     runs-on: ubuntu-latest
+    strategy:
+      fail-fast: false
+      matrix:
+        python-version:
+          - "3.10"
+          - "3.11"
+          - "3.12"
+          - "3.13"
+          # TODO: enable this https://github.com/openai/openai-agents-python/pull/1961/
+          # - "3.14"
     env:
       OPENAI_API_KEY: fake-for-tests
     steps:
@@ -50,6 +60,7 @@ jobs:
         uses: astral-sh/setup-uv@v5
         with:
           enable-cache: true
+          python-version: ${{ matrix.python-version }}
       - name: Install dependencies
         run: make sync
       - name: Run tests with coverage
@@ -71,7 +82,7 @@ jobs:
       - name: Build docs
         run: make build-docs
 
-  old_versions:
+  old_version_tests:
     runs-on: ubuntu-latest
     env:
       OPENAI_API_KEY: fake-for-tests

src/agents/realtime/openai_realtime.py

@@ -266,7 +266,8 @@ def remove_listener(self, listener: RealtimeModelListener) -> None:
 
     async def _emit_event(self, event: RealtimeModelEvent) -> None:
         """Emit an event to the listeners."""
-        for listener in self._listeners:
+        # Copy list to avoid modification during iteration
+        for listener in list(self._listeners):
             await listener.on_event(event)
 
     async def _listen_for_messages(self):
@@ -431,7 +432,7 @@ async def _send_interrupt(self, event: RealtimeModelSendInterrupt) -> None:
             and session.audio is not None
             and session.audio.input is not None
             and session.audio.input.turn_detection is not None
-            and session.audio.input.turn_detection.interrupt_response is True,
+            and session.audio.input.turn_detection.interrupt_response is True
         )
         if not automatic_response_cancellation_enabled:
             await self._cancel_response()
@@ -516,6 +517,10 @@ async def close(self) -> None:
             self._websocket = None
         if self._websocket_task:
             self._websocket_task.cancel()
+            try:
+                await self._websocket_task
+            except asyncio.CancelledError:
+                pass
             self._websocket_task = None
 
     async def _cancel_response(self) -> None:
@@ -616,7 +621,7 @@ async def _handle_ws_event(self, event: dict[str, Any]):
                     and session.audio is not None
                     and session.audio.input is not None
                     and session.audio.input.turn_detection is not None
-                    and session.audio.input.turn_detection.interrupt_response is True,
+                    and session.audio.input.turn_detection.interrupt_response is True
                 )
                 if not automatic_response_cancellation_enabled:
                     await self._cancel_response()