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

Fix error handling in DeepramSageMakerSTTService

Browse Source
This commit is contained in:
Mark Backman
2025-11-26 20:01:29 -05:00
parent fda327b3ee
commit bedd40ae8b
1 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/pipecat/services/deepgram/stt_sagemaker.py
View File

@@ -210,8 +210,7 @@ class DeepgramSageMakerSTTService(STTService):
try: try:
await self._client.send_audio_chunk(audio) await self._client.send_audio_chunk(audio)
except Exception as e: except Exception as e:
logger.error(f"Error sending audio to SageMaker: {e}") yield ErrorFrame(error=f"Unknown error occurred: {e}")
await self.push_error(ErrorFrame(error=f"SageMaker STT error: {e}"))
yield None yield None
async def _connect(self): async def _connect(self):
@@ -260,8 +259,7 @@ class DeepgramSageMakerSTTService(STTService):
await self._call_event_handler("on_connected") await self._call_event_handler("on_connected")
except Exception as e: except Exception as e:
logger.error(f"Failed to connect to SageMaker: {e}") await self.push_error(error_msg=f"Unknown error occurred: {e}", exception=e)
await self.push_error(ErrorFrame(error=f"SageMaker connection error: {e}"))
await self._call_event_handler("on_connection_error", str(e)) await self._call_event_handler("on_connection_error", str(e))
async def _disconnect(self): async def _disconnect(self):
@@ -342,8 +340,7 @@ class DeepgramSageMakerSTTService(STTService):
except asyncio.CancelledError: except asyncio.CancelledError:
logger.debug("Response processor cancelled") logger.debug("Response processor cancelled")
except Exception as e: except Exception as e:
logger.error(f"Error processing responses: {e}", exc_info=True) await self.push_error(error_msg=f"Unknown error occurred: {e}", exception=e)
await self.push_error(ErrorFrame(error=f"SageMaker response error: {e}"))
finally: finally:
logger.debug("Response processor stopped") logger.debug("Response processor stopped")