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

improve error handling to log all error types

Browse Source
This commit is contained in:
jay
2025-12-15 23:18:44 +05:30
parent 59c3abeb92
commit 7e424d750e
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/pipecat/services/elevenlabs/stt.py
View File

@@ -710,6 +710,8 @@ class ElevenLabsRealtimeSTTService(WebsocketSTTService):
""" """
message_type = data.get("message_type") message_type = data.get("message_type")
error_types = ["transcriber_error", "input_error", "commit_throttled", "transcriber_error", "unaccepted_terms_error", "rate_limited", "queue_overflow", "resource_exhausted", "session_time_limit_exceeded", "chunk_size_exceeded", "insufficient_audio_activity"]
if message_type == "session_started": if message_type == "session_started":
logger.debug(f"ElevenLabs session started: {data}") logger.debug(f"ElevenLabs session started: {data}")
@@ -731,12 +733,14 @@ class ElevenLabsRealtimeSTTService(WebsocketSTTService):
error_msg = data.get("error", "Authentication error") error_msg = data.get("error", "Authentication error")
logger.error(f"ElevenLabs auth error: {error_msg}") logger.error(f"ElevenLabs auth error: {error_msg}")
await self.push_error(error_msg=f"Auth error: {error_msg}") await self.push_error(error_msg=f"Auth error: {error_msg}")
elif message_type == "quota_exceeded_error": elif message_type == "quota_exceeded_error":
error_msg = data.get("error", "Quota exceeded") error_msg = data.get("error", "Quota exceeded")
logger.error(f"ElevenLabs quota exceeded: {error_msg}") logger.error(f"ElevenLabs quota exceeded: {error_msg}")
await self.push_error(error_msg=f"Quota exceeded: {error_msg}") await self.push_error(error_msg=f"Quota exceeded: {error_msg}")
elif message_type in error_types:
error_msg = data.get("error", message_type)
logger.error(f"ElevenLabs socket error: {error_msg}")
await self.push_error(error_msg=f"ElevenLabs socket error: {error_msg}")
else: else:
logger.debug(f"Unknown message type: {message_type}") logger.debug(f"Unknown message type: {message_type}")