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

LLMUserAggregator: use queue_task_frame() to push user speaking frames

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-12-30 14:27:23 -08:00
parent d459465eb6
commit ba86fc2f08
1 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -561,12 +561,10 @@ class LLMUserAggregator(LLMContextAggregator):
await s.reset() await s.reset()
if params.enable_user_speaking_frames: if params.enable_user_speaking_frames:
# TODO(aleix): This frame should really come from the top of the pipeline. await self.queue_task_frame(UserStartedSpeakingFrame())
await self.broadcast_frame(UserStartedSpeakingFrame)
if params.enable_interruptions and self._allow_interruptions: if params.enable_interruptions and self._allow_interruptions:
# TODO(aleix): This frame should really come from the top of the pipeline. await self.queue_task_frame(InterruptionFrame())
await self.broadcast_frame(InterruptionFrame)
await self._call_event_handler("on_user_turn_started", strategy) await self._call_event_handler("on_user_turn_started", strategy)
@@ -588,8 +586,7 @@ class LLMUserAggregator(LLMContextAggregator):
await s.reset() await s.reset()
if params.enable_user_speaking_frames: if params.enable_user_speaking_frames:
# TODO(aleix): This frame should really come from the top of the pipeline. await self.queue_task_frame(UserStoppedSpeakingFrame())
await self.broadcast_frame(UserStoppedSpeakingFrame)
await self._call_event_handler("on_user_turn_stopped", strategy) await self._call_event_handler("on_user_turn_stopped", strategy)