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

examples: update all examples to use the new LLMContextAggregatorPair tuple

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2026-01-13 13:40:03 -08:00
parent 1ab3bf2ef6
commit 861588e4a3
155 changed files with 450 additions and 475 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -249,7 +249,7 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
]
context = LLMContext(messages)
context_aggregator = LLMContextAggregatorPair(
user_aggregator, assistant_aggregator = LLMContextAggregatorPair(
context,
user_params=LLMUserAggregatorParams(
user_turn_strategies=UserTurnStrategies(
@@ -257,7 +257,7 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
),
),
)
audio_collector = UserAudioCollector(context, context_aggregator.user())
audio_collector = UserAudioCollector(context, user_aggregator)
pull_transcript_out_of_llm_output = TranscriptExtractor(context)
fixup_context_messages = TranscriptionContextFixup(context)
@@ -265,12 +265,12 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
[
transport.input(), # Transport user input
audio_collector,
context_aggregator.user(), # User responses
user_aggregator, # User responses
llm, # LLM
pull_transcript_out_of_llm_output,
tts, # TTS
transport.output(), # Transport bot output
context_aggregator.assistant(), # Assistant spoken responses
assistant_aggregator, # Assistant spoken responses
fixup_context_messages,
]
)