chore: format

backend/open_webui/migrations/versions/9a1b2c3d4e5f_add_current_message_id_to_chat.py

@@ -166,9 +166,7 @@ def upgrade() -> None:
 
             for chat_id, messages in messages_by_chat.items():
                 parent_ids = {
-                    message['parent_id']
-                    for message in messages.values()
-                    if message.get('parent_id') in messages
+                    message['parent_id'] for message in messages.values() if message.get('parent_id') in messages
                 }
                 leaf_ids = [message_id for message_id in messages if message_id not in parent_ids]
                 resolved[chat_id] = max(
@@ -189,9 +187,7 @@ def upgrade() -> None:
                 resolved[chat_id] = valid_candidate
             elif messages:
                 parent_ids = {
-                    message['parent_id']
-                    for message in messages.values()
-                    if message.get('parent_id') in messages
+                    message['parent_id'] for message in messages.values() if message.get('parent_id') in messages
                 }
                 leaf_ids = [message_id for message_id in messages if message_id not in parent_ids]
                 resolved[chat_id] = max(

backend/open_webui/models/functions.py

@@ -295,9 +295,7 @@ class FunctionsTable:
                 log.exception(f'Error getting function valves by id {id}: {e}')
                 return None
 
-    async def get_function_valves_by_ids(
-        self, ids: list[str], db: AsyncSession | None = None
-    ) -> dict[str, dict]:
+    async def get_function_valves_by_ids(self, ids: list[str], db: AsyncSession | None = None) -> dict[str, dict]:
         """
         Batch fetch valves for multiple functions in a single query.
         Returns a dict mapping function_id -> valves dict.

backend/open_webui/routers/chats.py

@@ -1602,7 +1602,9 @@ async def fork_chat_by_id(
             detail='Wait for the current response to finish before forking.',
         )
 
-    source_message_id = (form_data.message_id if form_data else None) or chat.current_message_id or history.get('currentId')
+    source_message_id = (
+        (form_data.message_id if form_data else None) or chat.current_message_id or history.get('currentId')
+    )
     if not source_message_id:
         raise HTTPException(status_code=status.HTTP_400_BAD_REQUEST, detail='chat has no messages to fork')
 

backend/open_webui/socket/main.py

@@ -57,6 +57,7 @@ REDIS = None
 # Configure CORS for Socket.IO
 SOCKETIO_CORS_ORIGINS = '*' if CORS_ALLOW_ORIGIN == ['*'] else CORS_ALLOW_ORIGIN
 
+
 class LocalFilteredRedisManager(socketio.AsyncRedisManager):
     """AsyncRedisManager that drops pub/sub emits with no local recipients.