diff --git a/src/pipecat/processors/aggregators/llm_response.py b/src/pipecat/processors/aggregators/llm_response.py index 1f50119fd..0bc68efdb 100644 --- a/src/pipecat/processors/aggregators/llm_response.py +++ b/src/pipecat/processors/aggregators/llm_response.py @@ -287,7 +287,7 @@ class LLMUserContextAggregator(LLMContextResponseAggregator): await self.push_aggregation() async def _handle_transcription(self, frame: TranscriptionFrame): - self._aggregation += frame.text + self._aggregation += f" {frame.text}" if self._aggregation else frame.text # We just got a final result, so let's reset interim results. self._seen_interim_results = False # Reset aggregation timer. diff --git a/tests/test_llm_response.py b/tests/test_context_aggregators.py similarity index 98% rename from tests/test_llm_response.py rename to tests/test_context_aggregators.py index e0026f5b5..a8e69da09 100644 --- a/tests/test_llm_response.py +++ b/tests/test_context_aggregators.py @@ -109,7 +109,7 @@ class BaseTestUserContextAggregator: aggregator = self.AGGREGATOR_CLASS(context) frames_to_send = [ UserStartedSpeakingFrame(), - TranscriptionFrame(text="Hello Pipecat! ", user_id="cat", timestamp=""), + TranscriptionFrame(text="Hello Pipecat!", user_id="cat", timestamp=""), InterimTranscriptionFrame(text="How ", user_id="cat", timestamp=""), SleepFrame(), UserStoppedSpeakingFrame(), @@ -271,7 +271,7 @@ class BaseTestUserContextAggregator: frames_to_send = [ UserStartedSpeakingFrame(), UserStoppedSpeakingFrame(), - TranscriptionFrame(text="Hello Pipecat! ", user_id="cat", timestamp=""), + TranscriptionFrame(text="Hello Pipecat!", user_id="cat", timestamp=""), TranscriptionFrame(text="How are you?", user_id="cat", timestamp=""), SleepFrame(sleep=AGGREGATION_SLEEP), ] @@ -298,7 +298,7 @@ class BaseTestUserContextAggregator: InterimTranscriptionFrame(text="Hello ", user_id="cat", timestamp=""), SleepFrame(), UserStoppedSpeakingFrame(), - TranscriptionFrame(text="Hello Pipecat! ", user_id="cat", timestamp=""), + TranscriptionFrame(text="Hello Pipecat!", user_id="cat", timestamp=""), InterimTranscriptionFrame(text="How ", user_id="cat", timestamp=""), TranscriptionFrame(text="How are you?", user_id="cat", timestamp=""), SleepFrame(sleep=AGGREGATION_SLEEP),