Change LLMContextAggregatorPair.create(context) to LLMContextAggregatorPair(context)

examples/foundational/14w-function-calling-universal-context.py

@@ -119,7 +119,7 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
     ]
 
     context = LLMContext(messages, tools)
-    context_aggregator = LLMContextAggregatorPair.create(context)
+    context_aggregator = LLMContextAggregatorPair(context)
 
     pipeline = Pipeline(
         [

examples/foundational/14x-function-calling-google-universal-context.py

@@ -172,7 +172,7 @@ indicate you should use the get_image tool are:
     ]
 
     context = LLMContext(messages, tools)
-    context_aggregator = LLMContextAggregatorPair.create(context)
+    context_aggregator = LLMContextAggregatorPair(context)
 
     pipeline = Pipeline(
         [

src/pipecat/processors/aggregators/llm_response_universal.py

@@ -795,38 +795,25 @@ class LLMAssistantAggregator(LLMContextAggregator):
         asyncio.run_coroutine_threadsafe(self.wait_for_task(task), self.get_event_loop())
 
 
-@dataclass
 class LLMContextAggregatorPair:
-    """Pair of LLM context aggregators for user and assistant messages.
+    """Pair of LLM context aggregators for updating context with user and assistant messages."""
 
-    Parameters:
+    def __init__(
-        _user: User context aggregator for processing user messages.
+        self,
-        _assistant: Assistant context aggregator for processing assistant messages.
-    """
-
-    _user: LLMUserAggregator
-    _assistant: LLMAssistantAggregator
-
-    @staticmethod
-    def create(
         context: LLMContext,
         *,
         user_params: LLMUserAggregatorParams = LLMUserAggregatorParams(),
         assistant_params: LLMAssistantAggregatorParams = LLMAssistantAggregatorParams(),
-    ) -> "LLMContextAggregatorPair":
+    ):
-        """Factory method to create an LLMContextAggregatorPair.
+        """Initialize the LLM context aggregator pair.
 
         Args:
-            context: The context managed by the aggregators.
+            context: The context to be managed by the aggregators.
             user_params: Parameters for the user context aggregator.
             assistant_params: Parameters for the assistant context aggregator.
-
-        Returns:
-            LLMContextAggregatorPair: A new instance with configured aggregators.
         """
-        user = LLMUserAggregator(context, params=user_params)
+        self._user = LLMUserAggregator(context, params=user_params)
-        assistant = LLMAssistantAggregator(context, params=assistant_params)
+        self._assistant = LLMAssistantAggregator(context, params=assistant_params)
-        return LLMContextAggregatorPair(_user=user, _assistant=assistant)
 
     def user(self) -> LLMUserAggregator:
         """Get the user context aggregator.