diff --git a/src/pipecat/services/cartesia.py b/src/pipecat/services/cartesia.py index ad4636a74..f92a78aa4 100644 --- a/src/pipecat/services/cartesia.py +++ b/src/pipecat/services/cartesia.py @@ -210,6 +210,8 @@ class CartesiaTTSService(WordTTSService): async def _handle_interruption(self, frame: StartInterruptionFrame, direction: FrameDirection): await super()._handle_interruption(frame, direction) await self.stop_all_metrics() + cancel_msg = json.dumps({"context_id": self._context_id, "cancel": True}) + await self._get_websocket().send(cancel_msg) self._context_id = None async def flush_audio(self):