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

LLMAssistantAggregator: reset aggregation after adding the thought, not before

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2026-01-12 09:07:23 -08:00
parent 1df9575e20
commit ec20d72aba
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -950,7 +950,6 @@ class LLMAssistantAggregator(LLMContextAggregator):
return return
thought = concatenate_aggregated_text(self._thought_aggregation) thought = concatenate_aggregated_text(self._thought_aggregation)
await self._reset_thought_aggregation()
if self._thought_append_to_context: if self._thought_append_to_context:
llm = self._thought_llm llm = self._thought_llm
@@ -966,6 +965,9 @@ class LLMAssistantAggregator(LLMContextAggregator):
) )
message = AssistantThoughtMessage(content=thought, timestamp=self._thought_start_time) message = AssistantThoughtMessage(content=thought, timestamp=self._thought_start_time)
await self._reset_thought_aggregation()
await self._call_event_handler("on_assistant_thought", message) await self._call_event_handler("on_assistant_thought", message)
def _context_updated_task_finished(self, task: asyncio.Task): def _context_updated_task_finished(self, task: asyncio.Task):