From 3b751322d3d18832b4fca299624eae710c7ed2af Mon Sep 17 00:00:00 2001
From: Pyae Sone Myo <66440980+Rickaym@users.noreply.github.com>
Date: Tue, 14 Oct 2025 23:04:09 +0630
Subject: [PATCH] fix: add interruption reset for partial word states

---
 src/pipecat/services/elevenlabs/tts.py | 14 +++++++++-----
 1 file changed, 9 insertions(+), 5 deletions(-)

diff --git a/src/pipecat/services/elevenlabs/tts.py b/src/pipecat/services/elevenlabs/tts.py
index 4c91c4f38..9e4154e4d 100644
--- a/src/pipecat/services/elevenlabs/tts.py
+++ b/src/pipecat/services/elevenlabs/tts.py
@@ -577,6 +577,8 @@ class ElevenLabsTTSService(AudioContextWordTTSService):
                 logger.error(f"Error closing context on interruption: {e}")
             self._context_id = None
             self._started = False
+            self._partial_word = ""
+            self._partial_word_start_time = 0.0
 
     async def _receive_messages(self):
         """Handle incoming WebSocket messages from ElevenLabs."""
@@ -616,11 +618,13 @@ class ElevenLabsTTSService(AudioContextWordTTSService):
 
             if msg.get("alignment"):
                 alignment = msg["alignment"]
-                word_times, self._partial_word, self._partial_word_start_time = calculate_word_times(
-                    alignment,
-                    self._cumulative_time,
-                    self._partial_word,
-                    self._partial_word_start_time,
+                word_times, self._partial_word, self._partial_word_start_time = (
+                    calculate_word_times(
+                        alignment,
+                        self._cumulative_time,
+                        self._partial_word,
+                        self._partial_word_start_time,
+                    )
                 )
 
                 if word_times: