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

LLMUserAggregator: remove auto ExternalUserTurnStrategies()

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2026-04-02 11:52:26 -07:00
parent cc3af59db4
commit 380867a87a
1 changed files with 1 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/pipecat/processors/aggregators/llm_response_universal.py
View File

@@ -50,7 +50,6 @@ from pipecat.frames.frames import (
LLMThoughtStartFrame, LLMThoughtStartFrame,
LLMThoughtTextFrame, LLMThoughtTextFrame,
LLMUpdateSettingsFrame, LLMUpdateSettingsFrame,
SpeechControlParamsFrame,
StartFrame, StartFrame,
TextFrame, TextFrame,
TranscriptionFrame, 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_stop import BaseUserTurnStopStrategy, UserTurnStoppedParams
from pipecat.turns.user_turn_completion_mixin import UserTurnCompletionConfig from pipecat.turns.user_turn_completion_mixin import UserTurnCompletionConfig
from pipecat.turns.user_turn_controller import UserTurnController 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 ( from pipecat.utils.context.llm_context_summarization import (
LLMAutoContextSummarizationConfig, LLMAutoContextSummarizationConfig,
LLMContextSummarizationConfig, LLMContextSummarizationConfig,
@@ -528,8 +527,6 @@ class LLMUserAggregator(LLMContextAggregator):
await self.push_frame(frame, direction) await self.push_frame(frame, direction)
elif isinstance(frame, LLMSetToolChoiceFrame): elif isinstance(frame, LLMSetToolChoiceFrame):
self.set_tool_choice(frame.tool_choice) self.set_tool_choice(frame.tool_choice)
elif isinstance(frame, SpeechControlParamsFrame):
await self._handle_speech_control_params(frame)
else: else:
await self.push_frame(frame, direction) await self.push_frame(frame, direction)
@@ -643,17 +640,6 @@ class LLMUserAggregator(LLMContextAggregator):
if frame.run_llm: if frame.run_llm:
await self.push_context_frame() 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): async def _handle_transcription(self, frame: TranscriptionFrame):
text = frame.text text = frame.text