From 816b3a95456a80c909d58154ab0a1e21c5109aa7 Mon Sep 17 00:00:00 2001 From: Filipi Fuchter Date: Fri, 11 Apr 2025 15:37:16 -0300 Subject: [PATCH] Fixing ruff format --- src/pipecat/transports/network/webrtc_connection.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/pipecat/transports/network/webrtc_connection.py b/src/pipecat/transports/network/webrtc_connection.py index 7e8dd8a0f..d4e3224ed 100644 --- a/src/pipecat/transports/network/webrtc_connection.py +++ b/src/pipecat/transports/network/webrtc_connection.py @@ -43,9 +43,11 @@ class TrackStatusMessage(BaseModel): class RenegotiateMessage(BaseModel): type: Literal["renegotiate"] = "renegotiate" + class PeerLeftMessage(BaseModel): type: Literal["peerLeft"] = "peerLeft" + class SignallingMessage: Inbound = Union[TrackStatusMessage] # in case we need to add new messages in the future outbound = Union[RenegotiateMessage] @@ -274,9 +276,7 @@ class SmallWebRTCConnection(BaseObject): logger.warning("Video transceiver not found. Cannot replace video track.") async def disconnect(self): - self.send_app_message( - {"type": SIGNALLING_TYPE, "message": PeerLeftMessage().model_dump()} - ) + self.send_app_message({"type": SIGNALLING_TYPE, "message": PeerLeftMessage().model_dump()}) await self._close() async def _close(self):