format

Author: typester

examples/room_example.py

@@ -49,10 +49,7 @@ def on_track_subscribed(
         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}")

examples/video-stream/audio_wave.py

@@ -15,8 +15,7 @@
     import cv2
 except ImportError:
     raise RuntimeError(
-        "cv2 is required to run this example, "
-        "install with `pip install opencv-python`"
+        "cv2 is required to run this example, install with `pip install opencv-python`"
     )
 
 # ensure LIVEKIT_URL, LIVEKIT_API_KEY, and LIVEKIT_API_SECRET are set

examples/video-stream/video_play.py

@@ -195,7 +195,7 @@ async def _log_fps(av_sync: rtc.AVSynchronizer):
             first_video_frame, video_timestamp = await video_stream.__anext__()
             first_audio_frame, audio_timestamp = await audio_stream.__anext__()
             logger.info(
-                f"first video duration: {1/media_info.video_fps:.3f}s, "
+                f"first video duration: {1 / media_info.video_fps:.3f}s, "
                 f"first audio duration: {first_audio_frame.duration:.3f}s"
             )
             await av_sync.push(first_video_frame, video_timestamp)

livekit-rtc/livekit/rtc/synchronizer.py

@@ -179,16 +179,15 @@ async def wait_next_process(self) -> None:
             # check if significantly behind schedule
             if -sleep_time > self._max_delay_tolerance_secs:
                 logger.warning(
-                    f"Frame capture was behind schedule for "
-                    f"{-sleep_time * 1000:.2f} ms"
+                    f"Frame capture was behind schedule for {-sleep_time * 1000:.2f} ms"
                 )
                 self._next_frame_time = time.perf_counter()
 
     def after_process(self) -> None:
         """Update timing information after processing a frame."""
-        assert (
-            self._next_frame_time is not None
-        ), "wait_next_process must be called first"
+        assert self._next_frame_time is not None, (
+            "wait_next_process must be called first"
+        )
 
         # update timing information
         self._send_timestamps.append(time.perf_counter())