diff --git a/examples/foundational/22b-natural-conversation-proposal.py b/examples/foundational/22b-natural-conversation-proposal.py index 2289f9409..8f19618a8 100644 --- a/examples/foundational/22b-natural-conversation-proposal.py +++ b/examples/foundational/22b-natural-conversation-proposal.py @@ -117,12 +117,15 @@ class CompletenessCheck(FrameProcessor): async def process_frame(self, frame: Frame, direction: FrameDirection): await super().process_frame(frame, direction) + if isinstance(frame, TextFrame) and frame.text == "YES": logger.debug("Completeness check YES") await self.push_frame(UserStoppedSpeakingFrame()) await self._notifier.notify() elif isinstance(frame, TextFrame) and frame.text == "NO": logger.debug("Completeness check NO") + else: + await self.push_frame(frame, direction) class OutputGate(FrameProcessor): diff --git a/examples/foundational/22c-natural-conversation-mixed-llms.py b/examples/foundational/22c-natural-conversation-mixed-llms.py index a5ea1f480..e4509da9c 100644 --- a/examples/foundational/22c-natural-conversation-mixed-llms.py +++ b/examples/foundational/22c-natural-conversation-mixed-llms.py @@ -328,6 +328,8 @@ class CompletenessCheck(FrameProcessor): await self._notifier.notify() elif isinstance(frame, TextFrame) and frame.text == "NO": logger.debug("!!! Completeness check NO") + else: + await self.push_frame(frame, direction) class OutputGate(FrameProcessor): diff --git a/examples/foundational/22d-natural-conversation-gemini-audio.py b/examples/foundational/22d-natural-conversation-gemini-audio.py index edddf47c4..e21f93896 100644 --- a/examples/foundational/22d-natural-conversation-gemini-audio.py +++ b/examples/foundational/22d-natural-conversation-gemini-audio.py @@ -456,6 +456,8 @@ class CompletenessCheck(FrameProcessor): # logger.debug("!!! CompletenessCheck idle wait START") self._wakeup_time = time.time() + self.wait_time self._idle_task = self.create_task(self._idle_task_handler()) + else: + await self.push_frame(frame, direction) async def _idle_task_handler(self): try: diff --git a/examples/foundational/25-google-audio-in.py b/examples/foundational/25-google-audio-in.py index de130f8aa..1d90294cd 100644 --- a/examples/foundational/25-google-audio-in.py +++ b/examples/foundational/25-google-audio-in.py @@ -212,7 +212,7 @@ class InputTranscriptionFrameEmitter(FrameProcessor): elif isinstance(frame, LLMFullResponseEndFrame): await self.push_frame(LLMDemoTranscriptionFrame(text=self._aggregation.strip())) self._aggregation = "" - elif isinstance(frame, MetricsFrame): + else: await self.push_frame(frame, direction)