ruff

Author: typester

livekit-rtc/livekit/rtc/audio_filter.py

@@ -6,9 +6,7 @@
 
 
 class AudioFilter:
-    def __init__(
-        self, path: str, dependencies: Optional[List[str]] = None
-    ) -> None:
+    def __init__(self, path: str, dependencies: Optional[List[str]] = None) -> None:
         self._path = path
 
         req = proto_ffi.FfiRequest()

livekit-rtc/livekit/rtc/audio_stream.py

@@ -231,7 +231,9 @@ def _create_owned_stream_from_participant(
         )
         audio_stream_from_participant.track_source = track_source
         if self._audio_filter_module is not None:
-            audio_stream_from_participant.audio_filter_module_id = self._audio_filter_module
+            audio_stream_from_participant.audio_filter_module_id = (
+                self._audio_filter_module
+            )
         if self._audio_filter_options is not None:
             audio_stream_from_participant.audio_filter_options = json.dumps(
                 self._audio_filter_options

livekit-rtc/livekit/rtc/room.py

@@ -101,6 +101,7 @@ class RoomOptions:
     audio_filters: List[ModuleType] | None = None
     """Audio filters"""
 
+
 @dataclass
 class DataPacket:
     data: bytes
@@ -390,10 +391,12 @@ def on_participant_connected(participant):
                     dependencies=deps,
                 )
                 self._filter_instances[module] = audio_filter
-                req.connect.options.audio_filter_handles.append(proto_room.AudioFilterModule(
-                    module_id=str(id(module)),
-                    handle_id=audio_filter.handle(),
-                ))
+                req.connect.options.audio_filter_handles.append(
+                    proto_room.AudioFilterModule(
+                        module_id=str(id(module)),
+                        handle_id=audio_filter.handle(),
+                    )
+                )
 
         # subscribe before connecting so we don't miss any events
         self._ffi_queue = FfiClient.instance.queue.subscribe(self._loop)