From e06bd6049ee9b9c3e9ede5771006189a46157336 Mon Sep 17 00:00:00 2001 From: gokuljs Date: Fri, 29 Aug 2025 21:27:14 +0530 Subject: [PATCH 1/3] update flush operation in flush audio function under rime tts --- src/pipecat/services/rime/tts.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/pipecat/services/rime/tts.py b/src/pipecat/services/rime/tts.py index e18df2742..6ec0d5b8d 100644 --- a/src/pipecat/services/rime/tts.py +++ b/src/pipecat/services/rime/tts.py @@ -323,7 +323,7 @@ class RimeTTSService(AudioContextWordTTSService): return logger.trace(f"{self}: flushing audio") - await self._get_websocket().send(json.dumps({"text": " "})) + await self._get_websocket().send(json.dumps({ "operation": "flush" })) self._context_id = None async def _receive_messages(self): From 5f801743d0c14bf2ab9ee6f7d104b649971db1c5 Mon Sep 17 00:00:00 2001 From: gokuljs Date: Mon, 1 Sep 2025 22:16:02 +0530 Subject: [PATCH 2/3] Add changelog entry for RimeTTSService flush_audio API update --- CHANGELOG.md | 2 ++ 1 file changed, 2 insertions(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index 5396a1eb7..ee81496a4 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -18,6 +18,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 - `pipecat.frames.frames.KeypadEntry` is deprecated and has been moved to `pipecat.audio.dtmf.types.KeypadEntry`. +- Updated `RimeTTSService`'s flush_audio message to conform with Rime's official API. + ## Removed - `DailyTransport.write_dtmf()` has been removed in favor of the generic From 472efa29712bcb93c11f661281fa92d30740c443 Mon Sep 17 00:00:00 2001 From: gokuljs Date: Tue, 2 Sep 2025 04:25:28 +0530 Subject: [PATCH 3/3] ruff format fix --- src/pipecat/services/rime/tts.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/pipecat/services/rime/tts.py b/src/pipecat/services/rime/tts.py index 6ec0d5b8d..be979b7f9 100644 --- a/src/pipecat/services/rime/tts.py +++ b/src/pipecat/services/rime/tts.py @@ -323,7 +323,7 @@ class RimeTTSService(AudioContextWordTTSService): return logger.trace(f"{self}: flushing audio") - await self._get_websocket().send(json.dumps({ "operation": "flush" })) + await self._get_websocket().send(json.dumps({"operation": "flush"})) self._context_id = None async def _receive_messages(self):