diff --git a/src/pipecat/services/asyncai/tts.py b/src/pipecat/services/asyncai/tts.py index b15b6b94b..a6b71ba60 100644 --- a/src/pipecat/services/asyncai/tts.py +++ b/src/pipecat/services/asyncai/tts.py @@ -288,7 +288,7 @@ class AsyncAITTSService(InterruptibleTTSService): logger.error(f"{self} error: {msg}") await self.push_frame(TTSStoppedFrame()) await self.stop_all_metrics() - await self.push_error(error_msg=f"{self} error: {msg['message']}", exception=e) + await self.push_error(error_msg=f"{self} error: {msg['message']}") else: logger.error(f"{self} error, unknown message type: {msg}") diff --git a/src/pipecat/services/cartesia/stt.py b/src/pipecat/services/cartesia/stt.py index 7a5a37725..342686365 100644 --- a/src/pipecat/services/cartesia/stt.py +++ b/src/pipecat/services/cartesia/stt.py @@ -317,7 +317,7 @@ class CartesiaSTTService(WebsocketSTTService): elif data["type"] == "error": error_msg = data.get("message", "Unknown error") - await self.push_error(error_msg=error_msg, exception=e) + await self.push_error(error_msg=error_msg) @traced_stt async def _handle_transcription( diff --git a/src/pipecat/services/cartesia/tts.py b/src/pipecat/services/cartesia/tts.py index 7bd7de3e1..850a27fd1 100644 --- a/src/pipecat/services/cartesia/tts.py +++ b/src/pipecat/services/cartesia/tts.py @@ -464,7 +464,7 @@ class CartesiaTTSService(AudioContextWordTTSService): elif msg["type"] == "error": await self.push_frame(TTSStoppedFrame()) await self.stop_all_metrics() - await self.push_error(error_msg=f"{self} error: {msg}", exception=e) + await self.push_error(error_msg=f"{self} error: {msg}") self._context_id = None else: logger.error(f"{self} error, unknown message type: {msg}") diff --git a/src/pipecat/transports/daily/transport.py b/src/pipecat/transports/daily/transport.py index 83d5ed888..d5e80aa47 100644 --- a/src/pipecat/transports/daily/transport.py +++ b/src/pipecat/transports/daily/transport.py @@ -2509,7 +2509,7 @@ class DailyTransport(BaseTransport): if self._input: await self._input.push_error(error_msg=error) elif self._output: - await self._input.push_error(error_msg=error) + await self._output.push_error(error_msg=error) else: logger.error("Both input and output are None while trying to push error") raise Exception("No valid input or output channel to push error")