wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add missing super().process_frame() calls

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-01-30 13:15:17 -08:00
parent a145005498
commit 642affb2fe
3 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
examples/foundational/06-listen-and-respond.py
View File

@@ -38,6 +38,8 @@ logger.add(sys.stderr, level="DEBUG")
class MetricsLogger(FrameProcessor): class MetricsLogger(FrameProcessor):
async def process_frame(self, frame: Frame, direction: FrameDirection): async def process_frame(self, frame: Frame, direction: FrameDirection):
await super().process_frame(frame, direction)
if isinstance(frame, MetricsFrame): if isinstance(frame, MetricsFrame):
for d in frame.data: for d in frame.data:
if isinstance(d, TTFBMetricsData): if isinstance(d, TTFBMetricsData):

2
src/pipecat/processors/filters/stt_mute_filter.py
View File

@@ -121,6 +121,8 @@ class STTMuteFilter(FrameProcessor):
return False return False
async def process_frame(self, frame: Frame, direction: FrameDirection): async def process_frame(self, frame: Frame, direction: FrameDirection):
await super().process_frame(frame, direction)
"""Processes incoming frames and manages muting state.""" """Processes incoming frames and manages muting state."""
# Handle function call state changes # Handle function call state changes
if isinstance(frame, FunctionCallInProgressFrame): if isinstance(frame, FunctionCallInProgressFrame):

2
src/pipecat/processors/logger.py
View File

@@ -31,6 +31,8 @@ class FrameLogger(FrameProcessor):
self._ignored_frame_types = tuple(ignored_frame_types) if ignored_frame_types else None self._ignored_frame_types = tuple(ignored_frame_types) if ignored_frame_types else None
async def process_frame(self, frame: Frame, direction: FrameDirection): 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): if self._ignored_frame_types and not isinstance(frame, self._ignored_frame_types):
dir = "<" if direction is FrameDirection.UPSTREAM else ">" dir = "<" if direction is FrameDirection.UPSTREAM else ">"
msg = f"{dir} {self._prefix}: {frame}" msg = f"{dir} {self._prefix}: {frame}"