wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix interruption frame to avoid issues with sending None

Browse Source
This commit is contained in:
balalo
2024-12-06 17:42:46 +01:00
parent bc699735a3
commit 9001cb17ce
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/pipecat/services/cartesia.py
View File

@@ -210,9 +210,10 @@ class CartesiaTTSService(WordTTSService):
async def _handle_interruption(self, frame: StartInterruptionFrame, direction: FrameDirection): async def _handle_interruption(self, frame: StartInterruptionFrame, direction: FrameDirection):
await super()._handle_interruption(frame, direction) await super()._handle_interruption(frame, direction)
await self.stop_all_metrics() await self.stop_all_metrics()
cancel_msg = json.dumps({"context_id": self._context_id, "cancel": True}) if not self._context_id:
await self._get_websocket().send(cancel_msg) cancel_msg = json.dumps({"context_id": self._context_id, "cancel": True})
self._context_id = None await self._get_websocket().send(cancel_msg)
self._context_id = None
async def flush_audio(self): async def flush_audio(self):
if not self._context_id or not self._websocket: if not self._context_id or not self._websocket: