cartesia: fix broken interruptions

2024-12-06 11:49:03 -08:00
parent e344a73d14
commit 7e41809ec2
1 changed files with 1 additions and 1 deletions
--- a/src/pipecat/services/cartesia.py
+++ b/src/pipecat/services/cartesia.py
@@ -227,7 +227,7 @@ class CartesiaTTSService(WordTTSService):
    async def _handle_interruption(self, frame: StartInterruptionFrame, direction: FrameDirection):
        await super()._handle_interruption(frame, direction)
        await self.stop_all_metrics()
-        if not self._context_id:
+        if self._context_id:
            cancel_msg = json.dumps({"context_id": self._context_id, "cancel": True})
            await self._get_websocket().send(cancel_msg)
            self._context_id = None