diff --git a/examples/room_example.py b/examples/room_example.py index f71ca963..336a762d 100644 --- a/examples/room_example.py +++ b/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}") diff --git a/examples/video-stream/audio_wave.py b/examples/video-stream/audio_wave.py index b00c31aa..9fbf1e76 100644 --- a/examples/video-stream/audio_wave.py +++ b/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 diff --git a/examples/video-stream/video_play.py b/examples/video-stream/video_play.py index 4fdbd21b..72b9b0bc 100644 --- a/examples/video-stream/video_play.py +++ b/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) diff --git a/livekit-rtc/livekit/rtc/synchronizer.py b/livekit-rtc/livekit/rtc/synchronizer.py index 14df3b6c..dda1ea0c 100644 --- a/livekit-rtc/livekit/rtc/synchronizer.py +++ b/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()) diff --git a/livekit-rtc/rust-sdks b/livekit-rtc/rust-sdks index e0846c2f..c6132e86 160000 --- a/livekit-rtc/rust-sdks +++ b/livekit-rtc/rust-sdks @@ -1 +1 @@ -Subproject commit e0846c2ff34de65e41ff6ab86a3400069fdb11e5 +Subproject commit c6132e864d33bd1def502693aa758eb157bdd7fc