aggregators: fix LLMUserResponseAggregator passs-through

pipecat-ai · Apr 11, 2024 · af8663e · af8663e
1 parent 1a0a66e
commit af8663e
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/dailyai/pipeline/aggregators.py b/src/dailyai/pipeline/aggregators.py
@@ -133,8 +133,9 @@ async def process_frame(self, frame: Frame) -> AsyncGenerator[Frame, None]:
                 self.aggregation = ""
                 yield self._end_frame()
                 yield LLMMessagesFrame(self.messages)
-        elif isinstance(frame, self._accumulator_frame) and self.aggregating:
-            self.aggregation += f" {frame.text}"
+        elif isinstance(frame, self._accumulator_frame):
+            if self.aggregating:
+                self.aggregation += f" {frame.text}"
             if self._pass_through:
                 yield frame
         else: