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

Port recent changes to LLMUserContextAggregator to universal LLMUserAggregator

Browse Source
This commit is contained in:
Paul Kompfner
2025-08-22 11:42:05 -04:00
parent f1f43fe500
commit baef688e4e
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -461,7 +461,7 @@ class LLMUserAggregator(LLMContextAggregator):
if self._vad_params if self._vad_params
else self._params.turn_emulated_vad_timeout 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() await self._maybe_emulate_user_speaking()
except asyncio.TimeoutError: except asyncio.TimeoutError:
if not self._user_speaking: if not self._user_speaking:
@@ -475,7 +475,6 @@ class LLMUserAggregator(LLMContextAggregator):
) )
self._emulating_vad = False self._emulating_vad = False
finally: finally:
self.reset_watchdog()
self._aggregation_event.clear() self._aggregation_event.clear()
async def _maybe_emulate_user_speaking(self): async def _maybe_emulate_user_speaking(self):