From cab9e18cc90d5d52c6485e5d97a8c26555a33cee Mon Sep 17 00:00:00 2001 From: Paul Kompfner Date: Fri, 22 Aug 2025 12:21:17 -0400 Subject: [PATCH] Port recent change to `LLMAssistantContextAggregator` to universal `LLMAssistantAggregator` --- src/pipecat/processors/aggregators/llm_response_universal.py | 4 ---- 1 file changed, 4 deletions(-) diff --git a/src/pipecat/processors/aggregators/llm_response_universal.py b/src/pipecat/processors/aggregators/llm_response_universal.py index 165b44596..e84194b78 100644 --- a/src/pipecat/processors/aggregators/llm_response_universal.py +++ b/src/pipecat/processors/aggregators/llm_response_universal.py @@ -788,10 +788,6 @@ class LLMAssistantAggregator(LLMContextAggregator): def _context_updated_task_finished(self, task: asyncio.Task): self._context_updated_tasks.discard(task) - # The task is finished so this should exit immediately. We need to do - # this because otherwise the task manager would report a dangling task - # if we don't remove it. - asyncio.run_coroutine_threadsafe(self.wait_for_task(task), self.get_event_loop()) class LLMContextAggregatorPair: