diff --git a/src/pipecat/services/ai_services.py b/src/pipecat/services/ai_services.py index a46ad3fab..0089a152e 100644 --- a/src/pipecat/services/ai_services.py +++ b/src/pipecat/services/ai_services.py @@ -260,7 +260,10 @@ class TTSService(AIService): self._stop_frame_task = None async def say(self, text: str): + aggregate_sentences = self._aggregate_sentences + self._aggregate_sentences = False await self.process_frame(TextFrame(text=text), FrameDirection.DOWNSTREAM) + self._aggregate_sentences = aggregate_sentences await self.flush_audio() async def process_frame(self, frame: Frame, direction: FrameDirection):