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

example 07s: minor typo updates

Browse Source
This commit is contained in:
vipyne
2025-09-03 12:10:29 -05:00
parent d19170d8b1
commit 83f64ecd3b
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
examples/foundational/07s-interruptible-google-audio-in.py
View File

@@ -93,9 +93,8 @@ class UserAudioCollector(FrameProcessor):
elif isinstance(frame, UserStoppedSpeakingFrame): elif isinstance(frame, UserStoppedSpeakingFrame):
self._user_speaking = False self._user_speaking = False
self._context.add_audio_frames_message(audio_frames=self._audio_frames) self._context.add_audio_frames_message(audio_frames=self._audio_frames)
await self._user_context_aggregator.push_frame( await self._user_context_aggregator.push_frame(LLMRunFrame())
self._user_context_aggregator.get_context_frame()
)
elif isinstance(frame, InputAudioRawFrame): elif isinstance(frame, InputAudioRawFrame):
if self._user_speaking: if self._user_speaking:
self._audio_frames.append(frame) self._audio_frames.append(frame)
@@ -151,7 +150,7 @@ class TranscriptExtractor(FrameProcessor):
await self.push_frame(frame, direction) await self.push_frame(frame, direction)
class TanscriptionContextFixup(FrameProcessor): class TranscriptionContextFixup(FrameProcessor):
def __init__(self, context): def __init__(self, context):
super().__init__() super().__init__()
self._context = context self._context = context
@@ -245,7 +244,7 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
context_aggregator = llm.create_context_aggregator(context) context_aggregator = llm.create_context_aggregator(context)
audio_collector = UserAudioCollector(context, context_aggregator.user()) audio_collector = UserAudioCollector(context, context_aggregator.user())
pull_transcript_out_of_llm_output = TranscriptExtractor(context) pull_transcript_out_of_llm_output = TranscriptExtractor(context)
fixup_context_messages = TanscriptionContextFixup(context) fixup_context_messages = TranscriptionContextFixup(context)
pipeline = Pipeline( pipeline = Pipeline(
[ [