From 642affb2fe5145be7ee36bfbad48150ba821918c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Thu, 30 Jan 2025 13:15:17 -0800 Subject: [PATCH] add missing super().process_frame() calls --- examples/foundational/06-listen-and-respond.py | 2 ++ src/pipecat/processors/filters/stt_mute_filter.py | 2 ++ src/pipecat/processors/logger.py | 2 ++ 3 files changed, 6 insertions(+) diff --git a/examples/foundational/06-listen-and-respond.py b/examples/foundational/06-listen-and-respond.py index 60550880a..8c349d567 100644 --- a/examples/foundational/06-listen-and-respond.py +++ b/examples/foundational/06-listen-and-respond.py @@ -38,6 +38,8 @@ logger.add(sys.stderr, level="DEBUG") class MetricsLogger(FrameProcessor): async def process_frame(self, frame: Frame, direction: FrameDirection): + await super().process_frame(frame, direction) + if isinstance(frame, MetricsFrame): for d in frame.data: if isinstance(d, TTFBMetricsData): diff --git a/src/pipecat/processors/filters/stt_mute_filter.py b/src/pipecat/processors/filters/stt_mute_filter.py index 65f224fc1..1a276df18 100644 --- a/src/pipecat/processors/filters/stt_mute_filter.py +++ b/src/pipecat/processors/filters/stt_mute_filter.py @@ -121,6 +121,8 @@ class STTMuteFilter(FrameProcessor): return False async def process_frame(self, frame: Frame, direction: FrameDirection): + await super().process_frame(frame, direction) + """Processes incoming frames and manages muting state.""" # Handle function call state changes if isinstance(frame, FunctionCallInProgressFrame): diff --git a/src/pipecat/processors/logger.py b/src/pipecat/processors/logger.py index a827642ba..09a2d1674 100644 --- a/src/pipecat/processors/logger.py +++ b/src/pipecat/processors/logger.py @@ -31,6 +31,8 @@ class FrameLogger(FrameProcessor): self._ignored_frame_types = tuple(ignored_frame_types) if ignored_frame_types else None async def process_frame(self, frame: Frame, direction: FrameDirection): + await super().process_frame(frame, direction) + if self._ignored_frame_types and not isinstance(frame, self._ignored_frame_types): dir = "<" if direction is FrameDirection.UPSTREAM else ">" msg = f"{dir} {self._prefix}: {frame}"