From 92dda3b58337646b3caf059413f73c4c90396a81 Mon Sep 17 00:00:00 2001
From: David Zhao <dz@livekit.io>
Date: Tue, 3 Dec 2024 23:52:35 -0800
Subject: [PATCH] fix formatting

---
 examples/room_example.py | 21 +++++++++++++--------
 1 file changed, 13 insertions(+), 8 deletions(-)

diff --git a/examples/room_example.py b/examples/room_example.py
index b13cfb07..67db8444 100644
--- a/examples/room_example.py
+++ b/examples/room_example.py
@@ -7,6 +7,7 @@
 TOKEN = os.environ.get("LIVEKIT_TOKEN")
 URL = os.environ.get("LIVEKIT_URL")
 
+
 async def main():
     logging.basicConfig(level=logging.INFO)
     logger = logging.getLogger(__name__)
@@ -14,8 +15,9 @@ async def main():
 
     @room.on("participant_connected")
     def on_participant_connected(participant: rtc.RemoteParticipant):
-        logging.info(
-            "participant connected: %s %s", participant.sid, participant.identity)
+        logger.info(
+            "participant connected: %s %s", participant.sid, participant.identity
+        )
 
     async def receive_frames(stream: rtc.VideoStream):
         async for frame in stream:
@@ -24,8 +26,12 @@ async def receive_frames(stream: rtc.VideoStream):
 
     # track_subscribed is emitted whenever the local participant is subscribed to a new track
     @room.on("track_subscribed")
-    def on_track_subscribed(track: rtc.Track, publication: rtc.RemoteTrackPublication, participant: rtc.RemoteParticipant):
-        logging.info("track subscribed: %s", publication.sid)
+    def on_track_subscribed(
+        track: rtc.Track,
+        publication: rtc.RemoteTrackPublication,
+        participant: rtc.RemoteParticipant,
+    ):
+        logger.info("track subscribed: %s", publication.sid)
         if track.kind == rtc.TrackKind.KIND_VIDEO:
             video_stream = rtc.VideoStream(track)
             asyncio.ensure_future(receive_frames(video_stream))
@@ -33,7 +39,7 @@ def on_track_subscribed(track: rtc.Track, publication: rtc.RemoteTrackPublicatio
     # By default, autosubscribe is enabled. The participant will be subscribed to
     # all published tracks in the room
     await room.connect(URL, TOKEN)
-    logging.info("connected to room %s", room.name)
+    logger.info("connected to room %s", room.name)
 
     for identity, participant in room.remote_participants.items():
         print(f"identity: {identity}")
@@ -43,7 +49,8 @@ def on_track_subscribed(track: rtc.Track, publication: rtc.RemoteTrackPublicatio
         print(f"participant identity: {participant.identity}")
         print(f"participant name: {participant.name}")
         print(f"participant kind: {participant.kind}")
-        print(f"participant track publications: {participant.track_publications}")
+        print(f"participant track publications: {
+              participant.track_publications}")
         for tid, publication in participant.track_publications.items():
             print(f"\ttrack id: {tid}")
             print(f"\t\ttrack publication: {publication}")
@@ -52,7 +59,6 @@ def on_track_subscribed(track: rtc.Track, publication: rtc.RemoteTrackPublicatio
             print(f"\t\ttrack source: {publication.source}")
 
         print(f"participant metadata: {participant.metadata}")
-        
 
 
 if __name__ == "__main__":
@@ -62,4 +68,3 @@ def on_track_subscribed(track: rtc.Track, publication: rtc.RemoteTrackPublicatio
         exit(1)
 
     asyncio.run(main())
-