Realtime: fix interrupt logic

Author: rm-openai

examples/realtime/app/server.py

@@ -138,7 +138,6 @@ async def websocket_endpoint(websocket: WebSocket, session_id: str):
 
             if message["type"] == "audio":
                 # Convert int16 array to bytes
-                print("Received audio data")
                 int16_data = message["data"]
                 audio_bytes = struct.pack(f"{len(int16_data)}h", *int16_data)
                 await manager.send_audio(session_id, audio_bytes)

src/agents/realtime/openai_realtime.py

@@ -150,7 +150,7 @@ async def connect(self, options: RealtimeModelConfig) -> None:
 
         model_settings: RealtimeSessionModelSettings = options.get("initial_model_settings", {})
 
-        self._playback_tracker = options.get("playback_tracker", RealtimePlaybackTracker())
+        self._playback_tracker = options.get("playback_tracker", None)
 
         self.model = model_settings.get("model_name", self.model)
         api_key = await get_api_key(options.get("api_key"))
@@ -351,6 +351,13 @@ async def _send_interrupt(self, event: RealtimeModelSendInterrupt) -> None:
                 int(elapsed_ms),
             )
             await self._send_raw_message(converted)
+        else:
+            logger.info(
+                "Didn't interrupt bc elapsed ms is < 0. "
+                f"Item id: {current_item_id}, "
+                f"elapsed ms: {elapsed_ms}, "
+                f"content index: {current_item_content_index}"
+            )
 
         automatic_response_cancellation_enabled = (
             self._created_session