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

Update check to exclude transcription frames

Browse Source
This commit is contained in:
Mark Backman
2025-01-16 16:43:46 -05:00
parent 67e47a388d
commit 119bc7e35f
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/pipecat/services/ai_services.py
View File

@@ -19,13 +19,14 @@ from pipecat.frames.frames import (
EndFrame, EndFrame,
ErrorFrame, ErrorFrame,
Frame, Frame,
InterimTranscriptionFrame,
LLMFullResponseEndFrame, LLMFullResponseEndFrame,
LLMTextFrame,
StartFrame, StartFrame,
StartInterruptionFrame, StartInterruptionFrame,
STTMuteFrame, STTMuteFrame,
STTUpdateSettingsFrame, STTUpdateSettingsFrame,
TextFrame, TextFrame,
TranscriptionFrame,
TTSAudioRawFrame, TTSAudioRawFrame,
TTSSpeakFrame, TTSSpeakFrame,
TTSStartedFrame, TTSStartedFrame,
@@ -291,7 +292,11 @@ class TTSService(AIService):
async def process_frame(self, frame: Frame, direction: FrameDirection): async def process_frame(self, frame: Frame, direction: FrameDirection):
await super().process_frame(frame, direction) await super().process_frame(frame, direction)
if isinstance(frame, LLMTextFrame): if (
isinstance(frame, TextFrame)
and not isinstance(frame, InterimTranscriptionFrame)
and not isinstance(frame, TranscriptionFrame)
):
await self._process_text_frame(frame) await self._process_text_frame(frame)
elif isinstance(frame, StartInterruptionFrame): elif isinstance(frame, StartInterruptionFrame):
await self._handle_interruption(frame, direction) await self._handle_interruption(frame, direction)