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}"