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

Refactoring services to use push_error.

Browse Source
This commit is contained in:
Filipi Fuchter
2025-11-19 15:54:43 -03:00
parent ede995c563
commit c1a1d40f9a
4 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/pipecat/services/asyncai/tts.py
View File

@@ -288,7 +288,7 @@ class AsyncAITTSService(InterruptibleTTSService):
logger.error(f"{self} error: {msg}") logger.error(f"{self} error: {msg}")
await self.push_frame(TTSStoppedFrame()) await self.push_frame(TTSStoppedFrame())
await self.stop_all_metrics() 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: else:
logger.error(f"{self} error, unknown message type: {msg}") logger.error(f"{self} error, unknown message type: {msg}")

2
src/pipecat/services/cartesia/stt.py
View File

@@ -317,7 +317,7 @@ class CartesiaSTTService(WebsocketSTTService):
elif data["type"] == "error": elif data["type"] == "error":
error_msg = data.get("message", "Unknown 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 @traced_stt
async def _handle_transcription( async def _handle_transcription(

2
src/pipecat/services/cartesia/tts.py
View File

@@ -464,7 +464,7 @@ class CartesiaTTSService(AudioContextWordTTSService):
elif msg["type"] == "error": elif msg["type"] == "error":
await self.push_frame(TTSStoppedFrame()) await self.push_frame(TTSStoppedFrame())
await self.stop_all_metrics() 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 self._context_id = None
else: else:
logger.error(f"{self} error, unknown message type: {msg}") logger.error(f"{self} error, unknown message type: {msg}")

2
src/pipecat/transports/daily/transport.py
View File

@@ -2509,7 +2509,7 @@ class DailyTransport(BaseTransport):
if self._input: if self._input:
await self._input.push_error(error_msg=error) await self._input.push_error(error_msg=error)
elif self._output: elif self._output:
await self._input.push_error(error_msg=error) await self._output.push_error(error_msg=error)
else: else:
logger.error("Both input and output are None while trying to push error") logger.error("Both input and output are None while trying to push error")
raise Exception("No valid input or output channel to push error") raise Exception("No valid input or output channel to push error")