diff --git a/src/pipecat/transports/network/fastapi_websocket.py b/src/pipecat/transports/network/fastapi_websocket.py index 2b3b49478..106bcb30d 100644 --- a/src/pipecat/transports/network/fastapi_websocket.py +++ b/src/pipecat/transports/network/fastapi_websocket.py @@ -102,7 +102,7 @@ class FastAPIWebsocketInputTransport(BaseInputTransport): else: await self.push_frame(frame) except Exception as e: - logger.error(f"{self} exception receiving data (class: {e.__class__.__name__})") + logger.error(f"{self} exception receiving data: {e.__class__.__name__} ({e})") await self._callbacks.on_client_disconnected(self._websocket) @@ -178,7 +178,7 @@ class FastAPIWebsocketOutputTransport(BaseOutputTransport): if payload and self._websocket.client_state == WebSocketState.CONNECTED: await self._send_data(payload) except Exception as e: - logger.error(f"{self} exception sending data (class: {e.__class__.__name__})") + logger.error(f"{self} exception sending data: {e.__class__.__name__} ({e})") def _send_data(self, data: str | bytes): if self._params.serializer.type == FrameSerializerType.BINARY: diff --git a/src/pipecat/transports/network/websocket_client.py b/src/pipecat/transports/network/websocket_client.py index a708ec5c6..2de4e2914 100644 --- a/src/pipecat/transports/network/websocket_client.py +++ b/src/pipecat/transports/network/websocket_client.py @@ -101,7 +101,7 @@ class WebsocketClientSession: if self._websocket: await self._websocket.send(message) except Exception as e: - logger.error(f"{self} exception sending data (class: {e.__class__.__name__})") + logger.error(f"{self} exception sending data: {e.__class__.__name__} ({e})") async def _client_task_handler(self): try: @@ -109,7 +109,7 @@ class WebsocketClientSession: async for message in self._websocket: await self._callbacks.on_message(self._websocket, message) except Exception as e: - logger.error(f"{self} exception receiving data (class: {e.__class__.__name__})") + logger.error(f"{self} exception receiving data: {e.__class__.__name__} ({e})") await self._callbacks.on_disconnected(self._websocket) diff --git a/src/pipecat/transports/network/websocket_server.py b/src/pipecat/transports/network/websocket_server.py index 860f20838..1d8420116 100644 --- a/src/pipecat/transports/network/websocket_server.py +++ b/src/pipecat/transports/network/websocket_server.py @@ -128,7 +128,7 @@ class WebsocketServerInputTransport(BaseInputTransport): else: await self.push_frame(frame) except Exception as e: - logger.error(f"{self} exception receiving data (class: {e.__class__.__name__})") + logger.error(f"{self} exception receiving data: {e.__class__.__name__} ({e})") # Notify disconnection await self._callbacks.on_client_disconnected(websocket) @@ -223,7 +223,7 @@ class WebsocketServerOutputTransport(BaseOutputTransport): if payload and self._websocket: await self._websocket.send(payload) except Exception as e: - logger.error(f"{self} exception sending data (class: {e.__class__.__name__})") + logger.error(f"{self} exception sending data: {e.__class__.__name__} ({e})") async def _write_audio_sleep(self): # Simulate a clock.