Compare commits
4 Commits
b3e1c3d380
...
6a42c47700
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
6a42c47700 | ||
|
|
3537a865f7 | ||
|
|
b34d500479 | ||
|
|
29d0b931eb |
@@ -466,7 +466,7 @@ class DuplexPipeline:
|
|||||||
}, priority=30)
|
}, priority=30)
|
||||||
|
|
||||||
if not is_final:
|
if not is_final:
|
||||||
logger.info(f"ASR interim: {text[:100]}")
|
logger.info(f"[ASR] ASR interim: {text[:100]}")
|
||||||
logger.debug(f"Sent transcript ({'final' if is_final else 'interim'}): {text[:50]}...")
|
logger.debug(f"Sent transcript ({'final' if is_final else 'interim'}): {text[:50]}...")
|
||||||
|
|
||||||
async def _on_speech_start(self, current_chunk: bytes = b"") -> None:
|
async def _on_speech_start(self, current_chunk: bytes = b"") -> None:
|
||||||
@@ -521,7 +521,7 @@ class DuplexPipeline:
|
|||||||
|
|
||||||
# Skip if no meaningful text
|
# Skip if no meaningful text
|
||||||
if not user_text or not user_text.strip():
|
if not user_text or not user_text.strip():
|
||||||
logger.debug("EOU detected but no transcription - skipping")
|
logger.debug("[EOU] Detected but no transcription - skipping")
|
||||||
# Reset for next utterance
|
# Reset for next utterance
|
||||||
self._audio_buffer = b""
|
self._audio_buffer = b""
|
||||||
self._last_sent_transcript = ""
|
self._last_sent_transcript = ""
|
||||||
@@ -529,7 +529,7 @@ class DuplexPipeline:
|
|||||||
await self.conversation.set_state(ConversationState.IDLE)
|
await self.conversation.set_state(ConversationState.IDLE)
|
||||||
return
|
return
|
||||||
|
|
||||||
logger.info(f"EOU detected - user said: {user_text[:100]}...")
|
logger.info(f"[EOU] Detected - user said: {user_text[:100]}...")
|
||||||
|
|
||||||
# For ASR backends that already emitted final via callback,
|
# For ASR backends that already emitted final via callback,
|
||||||
# avoid duplicating transcript.final on EOU.
|
# avoid duplicating transcript.final on EOU.
|
||||||
|
|||||||
Reference in New Issue
Block a user