From 25255f178e96b609ce920adf43eed1ee0b8a310e Mon Sep 17 00:00:00 2001 From: mkbk Date: Thu, 18 Jun 2026 12:32:03 +0800 Subject: [PATCH] =?UTF-8?q?[=E5=9B=9E=E5=A3=B0=E5=AD=97=E5=B9=95=E4=BF=AE?= =?UTF-8?q?=E5=A4=8D]=EF=BC=9A=E5=AE=8C=E6=88=90=E6=92=AD=E6=8A=A5?= =?UTF-8?q?=E9=98=B6=E6=AE=B5=E5=AE=9E=E6=97=B6=E5=AD=97=E5=B9=95=E9=9A=94?= =?UTF-8?q?=E7=A6=BB=EF=BC=8C=E5=8C=85=E5=90=AB=E9=9D=99=E9=BB=98=E6=89=93?= =?UTF-8?q?=E6=96=AD=E5=88=A4=E5=AE=9A=E5=92=8C=E5=9B=9E=E5=BD=92=E6=B5=8B?= =?UTF-8?q?=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/owner_voice_pet/assistant_pipeline.py | 6 ++++-- tests/test_live_runtime.py | 2 ++ 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/src/owner_voice_pet/assistant_pipeline.py b/src/owner_voice_pet/assistant_pipeline.py index efa5367..87d3122 100644 --- a/src/owner_voice_pet/assistant_pipeline.py +++ b/src/owner_voice_pet/assistant_pipeline.py @@ -542,8 +542,10 @@ class TurnController: result = self.vad_recorder.provider.analyze(frame) if result.is_speech: speech_ms += int(frame.metadata.get("duration_ms", 20)) - if realtime_session is not None and self._emit_realtime_transcript(realtime_session, frame, turn_id): - partial_seen = True + if realtime_session is not None: + transcript = realtime_session.accept_frame(frame) + if transcript is not None and is_valid_transcript_text(transcript.normalized_text): + partial_seen = True else: speech_ms = 0 detected = speech_ms >= self.config.barge_in_min_speech_ms and partial_seen diff --git a/tests/test_live_runtime.py b/tests/test_live_runtime.py index 0adda7f..1e4a336 100644 --- a/tests/test_live_runtime.py +++ b/tests/test_live_runtime.py @@ -541,10 +541,12 @@ class LiveRuntimeTests(unittest.TestCase): summary = runtime.run(max_turns=2) event_types = [event.type for event in runtime.event_bus.events] context_texts = [message.content for message in runtime.context.messages()] + playback_window = event_types[event_types.index(TTS_STARTED) : event_types.index(PLAYBACK_INTERRUPTED)] self.assertEqual(summary.completed_turns, 2) self.assertIn(BARGE_IN_DETECTED, event_types) self.assertIn(PLAYBACK_INTERRUPTED, event_types) + self.assertNotIn(TRANSCRIPT_PARTIAL, playback_window) self.assertIn("已播出一句。", context_texts) self.assertNotIn("这是一段需要被打断的很长很长很长很长很长很长很长很长的回复内容，没有播放完。", context_texts) self.assertEqual(reporter.transcripts[-1], "打断问题")