diff --git a/core/duplex_pipeline.py b/core/duplex_pipeline.py index 8a0211f..ec67d4b 100644 --- a/core/duplex_pipeline.py +++ b/core/duplex_pipeline.py @@ -388,6 +388,8 @@ class DuplexPipeline: self._last_sent_transcript = "" # Process the turn - trigger LLM response + # Cancel any existing turn to avoid overlapping assistant responses + await self._stop_current_speech() await self.conversation.end_user_turn(user_text) self._current_turn_task = asyncio.create_task(self._handle_turn(user_text))