diff --git a/src/pipecat/services/rime/tts.py b/src/pipecat/services/rime/tts.py index a11329309..075627d17 100644 --- a/src/pipecat/services/rime/tts.py +++ b/src/pipecat/services/rime/tts.py @@ -833,6 +833,7 @@ class RimeNonJsonTTSService(InterruptibleTTSService): # Send bare text (not JSON) await self._get_websocket().send(text) await self.start_tts_usage_metrics(text) + await self.flush_audio() except Exception as e: logger.error(f"{self} exception: {e}")