From 380867a87a90ef66ec634f1d11e0ed83bc6bd370 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Thu, 2 Apr 2026 11:52:26 -0700 Subject: [PATCH] LLMUserAggregator: remove auto ExternalUserTurnStrategies() --- .../aggregators/llm_response_universal.py | 16 +--------------- 1 file changed, 1 insertion(+), 15 deletions(-) diff --git a/src/pipecat/processors/aggregators/llm_response_universal.py b/src/pipecat/processors/aggregators/llm_response_universal.py index f8c2ffd43..fcc4fcf6d 100644 --- a/src/pipecat/processors/aggregators/llm_response_universal.py +++ b/src/pipecat/processors/aggregators/llm_response_universal.py @@ -50,7 +50,6 @@ from pipecat.frames.frames import ( LLMThoughtStartFrame, LLMThoughtTextFrame, LLMUpdateSettingsFrame, - SpeechControlParamsFrame, StartFrame, TextFrame, TranscriptionFrame, @@ -82,7 +81,7 @@ from pipecat.turns.user_start import BaseUserTurnStartStrategy, UserTurnStartedP from pipecat.turns.user_stop import BaseUserTurnStopStrategy, UserTurnStoppedParams from pipecat.turns.user_turn_completion_mixin import UserTurnCompletionConfig from pipecat.turns.user_turn_controller import UserTurnController -from pipecat.turns.user_turn_strategies import ExternalUserTurnStrategies, UserTurnStrategies +from pipecat.turns.user_turn_strategies import UserTurnStrategies from pipecat.utils.context.llm_context_summarization import ( LLMAutoContextSummarizationConfig, LLMContextSummarizationConfig, @@ -528,8 +527,6 @@ class LLMUserAggregator(LLMContextAggregator): await self.push_frame(frame, direction) elif isinstance(frame, LLMSetToolChoiceFrame): self.set_tool_choice(frame.tool_choice) - elif isinstance(frame, SpeechControlParamsFrame): - await self._handle_speech_control_params(frame) else: await self.push_frame(frame, direction) @@ -643,17 +640,6 @@ class LLMUserAggregator(LLMContextAggregator): if frame.run_llm: await self.push_context_frame() - async def _handle_speech_control_params(self, frame: SpeechControlParamsFrame): - if frame.id in self._self_queued_frames: - return - - if not frame.turn_params: - return - - logger.warning(f"{self}: `turn_analyzer` in base input transport is deprecated.") - - await self._user_turn_controller.update_strategies(ExternalUserTurnStrategies()) - async def _handle_transcription(self, frame: TranscriptionFrame): text = frame.text