From a9b23e060306e25fd97e7f888bdaa4c16ef8f83a Mon Sep 17 00:00:00 2001 From: Sreeram Sreedhar Date: Wed, 4 Nov 2026 12:28:26 -0700 Subject: [PATCH] docs(pipecat): update context aggregator example --- apps/docs/integrations/pipecat.mdx | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/apps/docs/integrations/pipecat.mdx b/apps/docs/integrations/pipecat.mdx index ae189343..a3717476 100644 --- a/apps/docs/integrations/pipecat.mdx +++ b/apps/docs/integrations/pipecat.mdx @@ -147,11 +147,11 @@ from fastapi import FastAPI, WebSocket from fastapi.middleware.cors import CORSMiddleware from pipecat.audio.vad.silero import SileroVADAnalyzer -from pipecat.frames.frames import LLMMessagesFrame from pipecat.pipeline.pipeline import Pipeline from pipecat.pipeline.runner import PipelineRunner -from pipecat.pipeline.task import PipelineParams, PipelineTask -from pipecat.processors.aggregators.openai_llm_context import OpenAILLMContext +from pipecat.pipeline.task import PipelineTask +from pipecat.processors.aggregators.llm_context import LLMContext +from pipecat.processors.aggregators.llm_response_universal import LLMContextAggregatorPair from pipecat.serializers.protobuf import ProtobufFrameSerializer from pipecat.services.openai.llm import OpenAILLMService from pipecat.services.openai.tts import OpenAITTSService @@ -198,8 +198,8 @@ async def run_bot(websocket_client, user_id: str, session_id: str): ), ) - context = OpenAILLMContext([{"role": "system", "content": SYSTEM_PROMPT}]) - context_aggregator = llm.create_context_aggregator(context) + context = LLMContext([{"role": "system", "content": SYSTEM_PROMPT}]) + context_aggregator = LLMContextAggregatorPair(context) pipeline = Pipeline([ transport.input(), @@ -212,7 +212,7 @@ async def run_bot(websocket_client, user_id: str, session_id: str): context_aggregator.assistant(), ]) - task = PipelineTask(pipeline, params=PipelineParams(allow_interruptions=True)) + task = PipelineTask(pipeline) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client):