upgrade ruff & format

Author: theomonnom

livekit-rtc/livekit/rtc/participant.py

@@ -318,9 +318,7 @@ async def perform_rpc(
         queue = FfiClient.instance.queue.subscribe()
         try:
             resp = FfiClient.instance.request(req)
-            cb = await queue.wait_for(
-                lambda e: (e.perform_rpc.async_id == resp.perform_rpc.async_id)
-            )
+            cb = await queue.wait_for(lambda e: e.perform_rpc.async_id == resp.perform_rpc.async_id)
         finally:
             FfiClient.instance.queue.unsubscribe(queue)
 

tests/rtc/test_e2e.py

@@ -314,9 +314,11 @@ def on_room2_track_unpublished(
         await room1.connect(url, token1)
 
         await assert_eventually(
-            lambda: len(events["connection_state_changed"]) > 0
-            and events["connection_state_changed"][-1]
-            == f"room1-{rtc.ConnectionState.CONN_CONNECTED}",
+            lambda: (
+                len(events["connection_state_changed"]) > 0
+                and events["connection_state_changed"][-1]
+                == f"room1-{rtc.ConnectionState.CONN_CONNECTED}"
+            ),
             message="room1 connection_state_changed event not fired or did not reach CONN_CONNECTED state",
         )
 
@@ -370,9 +372,13 @@ def on_room2_track_unpublished(
         await room1.disconnect()
 
         await assert_eventually(
-            lambda: lambda: len(events["connection_state_changed"]) > 0
-            and events["connection_state_changed"][-1]
-            == f"room1-{rtc.ConnectionState.CONN_DISCONNECTED}",
+            lambda: (
+                lambda: (
+                    len(events["connection_state_changed"]) > 0
+                    and events["connection_state_changed"][-1]
+                    == f"room1-{rtc.ConnectionState.CONN_DISCONNECTED}"
+                )
+            ),
             message="room1 disconnected event not fired",
         )