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

update error handling based on code review

Browse Source
This commit is contained in:
jay
2025-12-18 00:03:47 +05:30
parent 7e424d750e
commit 83a3295a39
1 changed files with 17 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -710,8 +710,6 @@ 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}")
@@ -724,23 +722,24 @@ class ElevenLabsRealtimeSTTService(WebsocketSTTService):
elif message_type == "committed_transcript_with_timestamps": elif message_type == "committed_transcript_with_timestamps":
await self._on_committed_transcript_with_timestamps(data) await self._on_committed_transcript_with_timestamps(data)
elif message_type == "error": elif message_type in (
error_msg = data.get("error", "Unknown error") "error",
logger.error(f"ElevenLabs error: {error_msg}") "auth_error",
"quota_exceeded_error",
"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",
):
error_msg = data.get("error", f"Unknown error - {message_type}")
await self.push_error(error_msg=f"Error: {error_msg}") await self.push_error(error_msg=f"Error: {error_msg}")
elif message_type == "auth_error":
error_msg = data.get("error", "Authentication error")
logger.error(f"ElevenLabs auth error: {error_msg}")
await self.push_error(error_msg=f"Auth error: {error_msg}")
elif message_type == "quota_exceeded_error":
error_msg = data.get("error", "Quota exceeded")
logger.error(f"ElevenLabs 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}")