[autofix.ci] apply automated fixes

Author: autofix-ci[bot]

api/controllers/console/app/conversation.py

@@ -172,7 +172,9 @@ def delete(self, app_model):
                 except Exception:
                     pass
                 try:
-                    db.session.query(MessageAgentThought).where(MessageAgentThought.message_id.in_(all_message_ids)).delete(synchronize_session=False)
+                    db.session.query(MessageAgentThought).where(
+                        MessageAgentThought.message_id.in_(all_message_ids)
+                    ).delete(synchronize_session=False)
                 except Exception:
                     pass
 
@@ -181,27 +183,31 @@ def delete(self, app_model):
                 db.session.query(Message).where(Message.conversation_id == conversation.id).delete()
                 db.session.query(MessageAnnotation).where(MessageAnnotation.conversation_id == conversation.id).delete()
                 try:
-                    db.session.query(ConversationVariable).where(ConversationVariable.conversation_id == conversation.id).delete()
+                    db.session.query(ConversationVariable).where(
+                        ConversationVariable.conversation_id == conversation.id
+                    ).delete()
                 except Exception:
                     pass  # Table might not exist in this version
                 try:
-                    db.session.query(ToolConversationVariables).where(ToolConversationVariables.conversation_id == conversation.id).delete()
+                    db.session.query(ToolConversationVariables).where(
+                        ToolConversationVariables.conversation_id == conversation.id
+                    ).delete()
                 except Exception:
                     pass  # Table might not exist in this version
                 try:
                     db.session.query(ToolFile).where(ToolFile.conversation_id == conversation.id).delete()
                 except Exception:
                     pass  # Table might not exist in this version
                 try:
-                    db.session.query(PinnedConversation).where(PinnedConversation.conversation_id == conversation.id).delete()
+                    db.session.query(PinnedConversation).where(
+                        PinnedConversation.conversation_id == conversation.id
+                    ).delete()
                 except Exception:
                     pass  # Table might not exist in this version
 
             # Delete upload file records
             if upload_file_ids:
-                db.session.query(UploadFile).where(UploadFile.id.in_(upload_file_ids)).delete(
-                    synchronize_session=False
-                )
+                db.session.query(UploadFile).where(UploadFile.id.in_(upload_file_ids)).delete(synchronize_session=False)
 
             # Delete conversations
             if args["conversation_ids"]:
@@ -465,7 +471,9 @@ def delete(self, app_model):
                 except Exception:
                     pass
                 try:
-                    db.session.query(MessageAgentThought).where(MessageAgentThought.message_id.in_(all_message_ids)).delete(synchronize_session=False)
+                    db.session.query(MessageAgentThought).where(
+                        MessageAgentThought.message_id.in_(all_message_ids)
+                    ).delete(synchronize_session=False)
                 except Exception:
                     pass
 
@@ -474,27 +482,31 @@ def delete(self, app_model):
                 db.session.query(Message).where(Message.conversation_id == conversation.id).delete()
                 db.session.query(MessageAnnotation).where(MessageAnnotation.conversation_id == conversation.id).delete()
                 try:
-                    db.session.query(ConversationVariable).where(ConversationVariable.conversation_id == conversation.id).delete()
+                    db.session.query(ConversationVariable).where(
+                        ConversationVariable.conversation_id == conversation.id
+                    ).delete()
                 except Exception:
                     pass  # Table might not exist in this version
                 try:
-                    db.session.query(ToolConversationVariables).where(ToolConversationVariables.conversation_id == conversation.id).delete()
+                    db.session.query(ToolConversationVariables).where(
+                        ToolConversationVariables.conversation_id == conversation.id
+                    ).delete()
                 except Exception:
                     pass  # Table might not exist in this version
                 try:
                     db.session.query(ToolFile).where(ToolFile.conversation_id == conversation.id).delete()
                 except Exception:
                     pass  # Table might not exist in this version
                 try:
-                    db.session.query(PinnedConversation).where(PinnedConversation.conversation_id == conversation.id).delete()
+                    db.session.query(PinnedConversation).where(
+                        PinnedConversation.conversation_id == conversation.id
+                    ).delete()
                 except Exception:
                     pass  # Table might not exist in this version
 
             # Delete upload file records
             if upload_file_ids:
-                db.session.query(UploadFile).where(UploadFile.id.in_(upload_file_ids)).delete(
-                    synchronize_session=False
-                )
+                db.session.query(UploadFile).where(UploadFile.id.in_(upload_file_ids)).delete(synchronize_session=False)
 
             # Delete conversations
             if args["conversation_ids"]:

api/tasks/clear_conversation_task.py

@@ -101,7 +101,8 @@ def clear_conversations_task(
                 # Get all message IDs for this batch
                 message_ids = [
                     row[0]
-                    for row in session.query(Message.id).where(Message.conversation_id.in_(conversation_batch_ids))
+                    for row in session.query(Message.id)
+                    .where(Message.conversation_id.in_(conversation_batch_ids))
                     .all()
                 ]