From f3c454dc54a0c96ee2dca479e81f367ba8be088a Mon Sep 17 00:00:00 2001
From: filipi87 <filipi87@gmail.com>
Date: Wed, 15 Apr 2026 13:19:36 -0300
Subject: [PATCH] Refactoring CartesiaSTT to use request to reconnect.

---
 src/pipecat/services/cartesia/stt.py | 4 +---
 src/pipecat/services/stt_service.py  | 1 +
 2 files changed, 2 insertions(+), 3 deletions(-)

diff --git a/src/pipecat/services/cartesia/stt.py b/src/pipecat/services/cartesia/stt.py
index e213652c1..2606e0d6d 100644
--- a/src/pipecat/services/cartesia/stt.py
+++ b/src/pipecat/services/cartesia/stt.py
@@ -323,9 +323,7 @@ class CartesiaSTTService(WebsocketSTTService):
         if not changed:
             return changed
 
-        if self._websocket:
-            await self._disconnect()
-            await self._connect()
+        await self._request_reconnect()
 
         return changed
 
diff --git a/src/pipecat/services/stt_service.py b/src/pipecat/services/stt_service.py
index 03c59b653..8fe83be33 100644
--- a/src/pipecat/services/stt_service.py
+++ b/src/pipecat/services/stt_service.py
@@ -626,6 +626,7 @@ class STTService(AIService):
         schedules a reconnect that fires as soon as ``UserStoppedSpeakingFrame``
         is received.
         """
+        logger.debug(f"{self} requesting to reconnect!")
         if self._can_reconnect:
             await self._reconnect()
         else: