From e7c83c19b65e4834a3c3a3642680370cb6ac7615 Mon Sep 17 00:00:00 2001 From: Mike Seese Date: Mon, 5 Jan 2026 10:36:08 -0800 Subject: [PATCH] port turn_start_strategies to the newer user_turn_strategies --- .../07ag-interruptible-hathora.py | 19 ++++++++++++++----- 1 file changed, 14 insertions(+), 5 deletions(-) diff --git a/examples/foundational/07ag-interruptible-hathora.py b/examples/foundational/07ag-interruptible-hathora.py index 9519937d5..9a90efb35 100644 --- a/examples/foundational/07ag-interruptible-hathora.py +++ b/examples/foundational/07ag-interruptible-hathora.py @@ -18,7 +18,10 @@ from pipecat.pipeline.pipeline import Pipeline from pipecat.pipeline.runner import PipelineRunner from pipecat.pipeline.task import PipelineParams, PipelineTask from pipecat.processors.aggregators.llm_context import LLMContext -from pipecat.processors.aggregators.llm_response_universal import LLMContextAggregatorPair +from pipecat.processors.aggregators.llm_response_universal import ( + LLMContextAggregatorPair, + LLMUserAggregatorParams, +) from pipecat.runner.types import RunnerArguments from pipecat.runner.utils import create_transport from pipecat.services.hathora.stt import HathoraSTTService @@ -27,6 +30,8 @@ from pipecat.services.openai.llm import OpenAILLMService from pipecat.transports.base_transport import BaseTransport, TransportParams from pipecat.transports.daily.transport import DailyParams from pipecat.transports.websocket.fastapi import FastAPIWebsocketParams +from pipecat.turns.user_stop import TurnAnalyzerUserTurnStopStrategy +from pipecat.turns.user_turn_strategies import UserTurnStrategies load_dotenv(override=True) @@ -78,7 +83,14 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): ] context = LLMContext(messages) - context_aggregator = LLMContextAggregatorPair(context) + context_aggregator = LLMContextAggregatorPair( + context, + user_params=LLMUserAggregatorParams( + user_turn_strategies=UserTurnStrategies( + stop=[TurnAnalyzerUserTurnStopStrategy(turn_analyzer=LocalSmartTurnAnalyzerV3())] + ), + ), + ) pipeline = Pipeline( [ @@ -97,9 +109,6 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): params=PipelineParams( enable_metrics=True, enable_usage_metrics=True, - turn_start_strategies=TurnStartStrategies( - bot=[TurnAnalyzerBotTurnStartStrategy(turn_analyzer=LocalSmartTurnAnalyzerV3())] - ), ), idle_timeout_secs=runner_args.pipeline_idle_timeout_secs, )