diff --git a/src/pipecat/services/gladia/stt.py b/src/pipecat/services/gladia/stt.py index c774c4257..316edd91c 100644 --- a/src/pipecat/services/gladia/stt.py +++ b/src/pipecat/services/gladia/stt.py @@ -15,7 +15,6 @@ import base64 import json import warnings from typing import Any, AsyncGenerator, Dict, Literal, Optional -from urllib.parse import urlencode import aiohttp from loguru import logger @@ -432,7 +431,7 @@ class GladiaSTTService(STTService): try: self._websocket = websocket self._connection_active = True - logger.info("Connected to Gladia WebSocket") + logger.debug(f"{self} Connected to Gladia WebSocket") # Send buffered audio if any await self._send_buffered_audio() @@ -525,7 +524,7 @@ class GladiaSTTService(STTService): """Send any buffered audio after reconnection.""" async with self._buffer_lock: if self._audio_buffer: - logger.info(f"Sending {len(self._audio_buffer)} bytes of buffered audio") + logger.debug(f"{self} Sending {len(self._audio_buffer)} bytes of buffered audio") await self._send_audio(bytes(self._audio_buffer)) async def _send_stop_recording(self): @@ -627,8 +626,8 @@ class GladiaSTTService(STTService): self._should_reconnect = False return False delay = self._reconnection_delay * (2 ** (self._reconnection_attempts - 1)) - logger.info( - f"Reconnecting in {delay} seconds (attempt {self._reconnection_attempts}/{self._max_reconnection_attempts})" + logger.debug( + f"{self} Reconnecting in {delay} seconds (attempt {self._reconnection_attempts}/{self._max_reconnection_attempts})" ) await asyncio.sleep(delay) return True