From bedd40ae8b2fb018a7c12fdd728c067d73010f13 Mon Sep 17 00:00:00 2001 From: Mark Backman Date: Wed, 26 Nov 2025 20:01:29 -0500 Subject: [PATCH] Fix error handling in DeepramSageMakerSTTService --- src/pipecat/services/deepgram/stt_sagemaker.py | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/src/pipecat/services/deepgram/stt_sagemaker.py b/src/pipecat/services/deepgram/stt_sagemaker.py index 6d28feefa..cc765f83a 100644 --- a/src/pipecat/services/deepgram/stt_sagemaker.py +++ b/src/pipecat/services/deepgram/stt_sagemaker.py @@ -210,8 +210,7 @@ class DeepgramSageMakerSTTService(STTService): try: await self._client.send_audio_chunk(audio) except Exception as e: - logger.error(f"Error sending audio to SageMaker: {e}") - await self.push_error(ErrorFrame(error=f"SageMaker STT error: {e}")) + yield ErrorFrame(error=f"Unknown error occurred: {e}") yield None async def _connect(self): @@ -260,8 +259,7 @@ class DeepgramSageMakerSTTService(STTService): await self._call_event_handler("on_connected") except Exception as e: - logger.error(f"Failed to connect to SageMaker: {e}") - await self.push_error(ErrorFrame(error=f"SageMaker connection error: {e}")) + await self.push_error(error_msg=f"Unknown error occurred: {e}", exception=e) await self._call_event_handler("on_connection_error", str(e)) async def _disconnect(self): @@ -342,8 +340,7 @@ class DeepgramSageMakerSTTService(STTService): except asyncio.CancelledError: logger.debug("Response processor cancelled") except Exception as e: - logger.error(f"Error processing responses: {e}", exc_info=True) - await self.push_error(ErrorFrame(error=f"SageMaker response error: {e}")) + await self.push_error(error_msg=f"Unknown error occurred: {e}", exception=e) finally: logger.debug("Response processor stopped")