From baef688e4ec4006aef5605b36734fb9fe37fe0bb Mon Sep 17 00:00:00 2001 From: Paul Kompfner Date: Fri, 22 Aug 2025 11:42:05 -0400 Subject: [PATCH] Port recent changes to `LLMUserContextAggregator` to universal `LLMUserAggregator` --- src/pipecat/processors/aggregators/llm_response_universal.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/pipecat/processors/aggregators/llm_response_universal.py b/src/pipecat/processors/aggregators/llm_response_universal.py index 73a6909b4..165b44596 100644 --- a/src/pipecat/processors/aggregators/llm_response_universal.py +++ b/src/pipecat/processors/aggregators/llm_response_universal.py @@ -461,7 +461,7 @@ class LLMUserAggregator(LLMContextAggregator): if self._vad_params else self._params.turn_emulated_vad_timeout ) - await asyncio.wait_for(self._aggregation_event.wait(), timeout) + await asyncio.wait_for(self._aggregation_event.wait(), timeout=timeout) await self._maybe_emulate_user_speaking() except asyncio.TimeoutError: if not self._user_speaking: @@ -475,7 +475,6 @@ class LLMUserAggregator(LLMContextAggregator): ) self._emulating_vad = False finally: - self.reset_watchdog() self._aggregation_event.clear() async def _maybe_emulate_user_speaking(self):