wx44wx/AI-VideoAssistant
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix race asr problem

Browse Source
This commit is contained in:
Xin Wang
2026-02-09 18:01:40 +08:00
parent 088943166c
commit b57d9f3a65
2 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
engine/core/conversation.py
View File

@@ -205,7 +205,10 @@ class ConversationManager:
self._current_assistant_text = "" self._current_assistant_text = ""
if was_interrupted: if was_interrupted:
await self.set_state(ConversationState.INTERRUPTED) # A new user turn may already be active (LISTENING) when interrupted.
# Avoid overriding it back to INTERRUPTED, which can stall EOU flow.
if self.state != ConversationState.LISTENING:
await self.set_state(ConversationState.INTERRUPTED)
else: else:
await self.set_state(ConversationState.IDLE) await self.set_state(ConversationState.IDLE)

4
engine/core/duplex_pipeline.py
View File

@@ -420,7 +420,7 @@ class DuplexPipeline:
async def _on_speech_start(self) -> None: async def _on_speech_start(self) -> None:
"""Handle user starting to speak.""" """Handle user starting to speak."""
if self.conversation.state == ConversationState.IDLE: if self.conversation.state in (ConversationState.IDLE, ConversationState.INTERRUPTED):
await self.conversation.start_user_turn() await self.conversation.start_user_turn()
self._audio_buffer = b"" self._audio_buffer = b""
self._last_sent_transcript = "" self._last_sent_transcript = ""
@@ -436,7 +436,7 @@ class DuplexPipeline:
async def _on_end_of_utterance(self) -> None: async def _on_end_of_utterance(self) -> None:
"""Handle end of user utterance.""" """Handle end of user utterance."""
if self.conversation.state != ConversationState.LISTENING: if self.conversation.state not in (ConversationState.LISTENING, ConversationState.INTERRUPTED):
return return
# Stop interim transcriptions # Stop interim transcriptions