wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

GladiaSTTService: update loggin levels

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-08-21 18:41:25 -07:00
parent b61846534d
commit 4947d08733
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/pipecat/services/gladia/stt.py
View File

@@ -15,7 +15,6 @@ import base64
import json import json
import warnings import warnings
from typing import Any, AsyncGenerator, Dict, Literal, Optional from typing import Any, AsyncGenerator, Dict, Literal, Optional
from urllib.parse import urlencode
import aiohttp import aiohttp
from loguru import logger from loguru import logger
@@ -432,7 +431,7 @@ class GladiaSTTService(STTService):
try: try:
self._websocket = websocket self._websocket = websocket
self._connection_active = True self._connection_active = True
logger.info("Connected to Gladia WebSocket") logger.debug(f"{self} Connected to Gladia WebSocket")
# Send buffered audio if any # Send buffered audio if any
await self._send_buffered_audio() await self._send_buffered_audio()
@@ -525,7 +524,7 @@ class GladiaSTTService(STTService):
"""Send any buffered audio after reconnection.""" """Send any buffered audio after reconnection."""
async with self._buffer_lock: async with self._buffer_lock:
if self._audio_buffer: 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)) await self._send_audio(bytes(self._audio_buffer))
async def _send_stop_recording(self): async def _send_stop_recording(self):
@@ -627,8 +626,8 @@ class GladiaSTTService(STTService):
self._should_reconnect = False self._should_reconnect = False
return False return False
delay = self._reconnection_delay * (2 ** (self._reconnection_attempts - 1)) delay = self._reconnection_delay * (2 ** (self._reconnection_attempts - 1))
logger.info( logger.debug(
f"Reconnecting in {delay} seconds (attempt {self._reconnection_attempts}/{self._max_reconnection_attempts})" f"{self} Reconnecting in {delay} seconds (attempt {self._reconnection_attempts}/{self._max_reconnection_attempts})"
) )
await asyncio.sleep(delay) await asyncio.sleep(delay)
return True return True