♻️ Translate error messages and Chinese comments in backend code into English #1131

Author: Phinease

backend/apps/model_managment_app.py

@@ -115,7 +115,8 @@ async def create_provider_model(request: ProviderModelRequest, authorization: Op
         model_list = await get_provider_models(model_data)
 
         # Merge existing model's max_tokens attribute
-        model_list = merge_existing_model_tokens(model_list, tenant_id, request.provider, request.model_type)
+        model_list = merge_existing_model_tokens(
+            model_list, tenant_id, request.provider, request.model_type)
 
         # Sort model list by ID
         model_list = sort_models_by_id(model_list)
@@ -164,7 +165,8 @@ async def batch_create_models(request: BatchCreateModelsRequest, authorization:
                     existing_max_tokens = existing_model_by_display["max_tokens"]
                     new_max_tokens = model["max_tokens"]
                     if existing_max_tokens != new_max_tokens:
-                        update_model_record(existing_model_by_display["model_id"], {"max_tokens": new_max_tokens}, user_id)
+                        update_model_record(existing_model_by_display["model_id"], {
+                                            "max_tokens": new_max_tokens}, user_id)
                     continue
 
             model_dict = await prepare_model_dict(
@@ -267,7 +269,7 @@ async def delete_model(display_name: str = Query(..., embed=True), authorization
     If the model is an embedding or multi_embedding type, both types will be deleted
 
     Args:
-        display_name: Display name of the model to delete (唯一键)
+        display_name: Display name of the model to delete (unique key)
         authorization: Authorization header
     """
     try:
@@ -282,10 +284,10 @@ async def delete_model(display_name: str = Query(..., embed=True), authorization
                 message=f"Model not found: {display_name}",
                 data=None
             )
-        # 支持 embedding/multi_embedding 互删
+        # Support mutual deletion of embedding/multi_embedding
         deleted_types = []
         if model["model_type"] in ["embedding", "multi_embedding"]:
-            # 查找所有 embedding/multi_embedding 且 display_name 相同的模型
+            # Find all embedding/multi_embedding models with the same display_name
             for t in ["embedding", "multi_embedding"]:
                 m = get_model_by_display_name(display_name, tenant_id)
                 if m and m["model_type"] == t:

backend/consts/model.py

@@ -25,7 +25,7 @@ def get_value(cls, status: Optional[str]) -> str:
         return status
 
 
-# 用户认证相关请求模型
+# User authentication related request models
 class UserSignUpRequest(BaseModel):
     """User registration request model"""
     email: EmailStr

backend/database/utils.py

@@ -1,17 +1,17 @@
 from typing import Any, Dict
 
 
-# 全局追踪字段管理方法
+# Global tracking field management methods
 def add_creation_tracking(data: Dict[str, Any], user_id: str) -> Dict[str, Any]:
     """
-    添加创建追踪字段（created_by和updated_by）
+    Add creation tracking fields (created_by and updated_by)
 
     Args:
-        data: 要添加字段的数据字典
-        user_id: 当前用户ID
+        data: Data dictionary to add fields to
+        user_id: Current user ID
 
     Returns:
-        Dict[str, Any]: 添加追踪字段后的数据字典
+        Dict[str, Any]: Data dictionary with tracking fields added
     """
     data_copy = data.copy()
     data_copy["created_by"] = user_id
@@ -21,14 +21,14 @@ def add_creation_tracking(data: Dict[str, Any], user_id: str) -> Dict[str, Any]:
 
 def add_update_tracking(data: Dict[str, Any], user_id: str) -> Dict[str, Any]:
     """
-    添加更新追踪字段（updated_by）
+    Add update tracking field (updated_by)
 
     Args:
-        data: 要添加字段的数据字典
-        user_id: 当前用户ID
+        data: Data dictionary to add field to
+        user_id: Current user ID
 
     Returns:
-        Dict[str, Any]: 添加追踪字段后的数据字典
+        Dict[str, Any]: Data dictionary with tracking field added
     """
     data_copy = data.copy()
     data_copy["updated_by"] = user_id

backend/services/data_process_service.py

@@ -65,7 +65,8 @@ def _init_redis_client(self):
                     connection_pool=self.redis_pool)
                 logger.info("Redis client initialized successfully.")
             else:
-                logger.warning("REDIS_BACKEND_URL not set, Redis client not initialized.")
+                logger.warning(
+                    "REDIS_BACKEND_URL not set, Redis client not initialized.")
         except Exception as e:
             logger.error(f"Failed to initialize Redis client: {str(e)}")
 
@@ -82,7 +83,8 @@ def _init_clip_model(self):
             self.clip_available = True
             logger.info("CLIP model loaded successfully")
         except Exception as e:
-            logger.warning(f"Failed to load CLIP model, size-only filtering will be used: {str(e)}")
+            logger.warning(
+                f"Failed to load CLIP model, size-only filtering will be used: {str(e)}")
             self.clip_available = False
 
     async def start(self):
@@ -102,7 +104,8 @@ def _get_celery_inspector(self):
             if not celery_app.conf.broker_url or not celery_app.conf.result_backend:
                 celery_app.conf.broker_url = REDIS_URL
                 celery_app.conf.result_backend = REDIS_BACKEND_URL
-                logger.warning(f"Celery broker URL is not configured properly, reconfiguring to {celery_app.conf.broker_url}")
+                logger.warning(
+                    f"Celery broker URL is not configured properly, reconfiguring to {celery_app.conf.broker_url}")
             try:
                 inspector = celery_app.control.inspect()
                 inspector.ping()
@@ -176,8 +179,10 @@ def get_reserved():
                     # Add to the set, duplicates will be handled
                     task_ids.add(task_id)
             except Exception as redis_error:
-                logger.warning(f"Failed to query Redis for stored task IDs: {str(redis_error)}")
-            logger.debug(f"Total unique task IDs collected (inspector + Redis): {len(task_ids)}")
+                logger.warning(
+                    f"Failed to query Redis for stored task IDs: {str(redis_error)}")
+            logger.debug(
+                f"Total unique task IDs collected (inspector + Redis): {len(task_ids)}")
             tasks = [get_task_info(task_id) for task_id in task_ids]
             all_task_infos = await asyncio.gather(*tasks, return_exceptions=True)
             for task_info in all_task_infos:
@@ -366,7 +371,7 @@ async def filter_important_image(self, image_url: str, positive_prompt: str = "a
                     }
                 }
 
-            # 延迟加载CLIP模型
+            # Lazy load CLIP model
             if not self.clip_available:
                 self._init_clip_model()
 

backend/services/prompt_service.py

@@ -237,8 +237,8 @@ def _stream_results(produce_queue, latest, stop_flags, threads):
 
 
 def join_info_for_generate_system_prompt(prompt_for_generate, sub_agent_info_list, task_description, tool_info_list, language: str = 'zh'):
-    input_label = "接受输入" if language == 'zh' else "Inputs"
-    output_label = "返回输出类型" if language == 'zh' else "Output type"
+    input_label = "Inputs" if language == 'en' else "接受输入"
+    output_label = "Output type" if language == 'en' else "返回输出类型"
 
     tool_description = "\n".join(
         [f"- {tool['name']}: {tool['description']} \n {input_label}: {tool['inputs']}\n {output_label}: {tool['output_type']}"

backend/services/user_management_service.py

@@ -88,21 +88,21 @@ async def check_auth_service_health() -> bool:
     try:
         supabase_url = os.getenv("SUPABASE_URL")
         supabase_key = os.getenv("SUPABASE_KEY")
-        
+
         health_url = f'{supabase_url}/auth/v1/health'
         headers = {'apikey': supabase_key}
-        
+
         async with aiohttp.ClientSession() as session:
             async with session.get(health_url, headers=headers) as response:
                 if not response.ok:
                     return False
-                
+
                 data = await response.json()
                 # Check if the service is available by checking if the response contains the name field and its value is "GoTrue"
                 is_available = data and data.get("name") == "GoTrue"
-                
+
                 return is_available
-                    
+
     except aiohttp.ClientError as e:
         logging.error(f"Auth service connection failed: {str(e)}")
         return False
@@ -117,7 +117,8 @@ async def signup_user(email: EmailStr,
                       invite_code: Optional[str] = None):
     """User registration"""
     client = get_supabase_client()
-    logging.info(f"Receive registration request: email={email}, is_admin={is_admin}")
+    logging.info(
+        f"Receive registration request: email={email}, is_admin={is_admin}")
     if is_admin:
         await verify_invite_code(invite_code)
 
@@ -138,7 +139,8 @@ async def signup_user(email: EmailStr,
         # Create user tenant relationship
         insert_user_tenant(user_id=user_id, tenant_id=tenant_id)
 
-        logging.info(f"User {email} registered successfully, role: {user_role}, tenant: {tenant_id}")
+        logging.info(
+            f"User {email} registered successfully, role: {user_role}, tenant: {tenant_id}")
 
         if is_admin:
             await generate_tts_stt_4_admin(tenant_id, user_id)
@@ -147,7 +149,8 @@ async def signup_user(email: EmailStr,
     else:
         logging.error(
             "Supabase registration request returned no user object")
-        raise UserRegistrationException("Registration service is temporarily unavailable, please try again later")
+        raise UserRegistrationException(
+            "Registration service is temporarily unavailable, please try again later")
 
 
 async def parse_supabase_response(is_admin, response, user_role):
@@ -157,7 +160,7 @@ async def parse_supabase_response(is_admin, response, user_role):
         "email": response.user.email,
         "role": user_role
     }
-    
+
     session_data = None
     if response.session:
         session_data = {
@@ -166,7 +169,7 @@ async def parse_supabase_response(is_admin, response, user_role):
             "expires_at": calculate_expires_at(response.session.access_token),
             "expires_in_seconds": get_jwt_expiry_seconds(response.session.access_token)
         }
-    
+
     return {
         "user": user_data,
         "session": session_data,
@@ -206,7 +209,8 @@ async def generate_tts_stt_4_admin(tenant_id, user_id):
 
 
 async def verify_invite_code(invite_code):
-    logging.info("detect admin registration request, start verifying invite code")
+    logging.info(
+        "detect admin registration request, start verifying invite code")
     logging.info(f"The INVITE_CODE obtained from consts.const: {INVITE_CODE}")
     if not INVITE_CODE:
         logging.error("please check the INVITE_CODE environment variable")
@@ -219,7 +223,8 @@ async def verify_invite_code(invite_code):
     if invite_code != INVITE_CODE:
         logging.warning(
             f"Admin invite code verification failed: user provided='{invite_code}', system configured='{INVITE_CODE}'")
-        raise IncorrectInviteCodeException("Please enter the correct admin invite code")
+        raise IncorrectInviteCodeException(
+            "Please enter the correct admin invite code")
     logging.info("Admin invite code verification successful")
 
 
@@ -246,21 +251,21 @@ async def signin_user(email: EmailStr,
         f"User {email} logged in successfully, session validity is {expiry_seconds} seconds, role: {user_role}")
 
     return {
-            "message":f"Login successful, session validity is {expiry_seconds} seconds",
-            "data":{
-                "user": {
-                    "id": response.user.id,
-                    "email": response.user.email,
-                    "role": user_role
-                },
-                "session": {
-                    "access_token": response.session.access_token,
-                    "refresh_token": response.session.refresh_token,
-                    "expires_at": expires_at,
-                    "expires_in_seconds": expiry_seconds
-                }
+        "message": f"Login successful, session validity is {expiry_seconds} seconds",
+        "data": {
+            "user": {
+                "id": response.user.id,
+                "email": response.user.email,
+                "role": user_role
+            },
+            "session": {
+                "access_token": response.session.access_token,
+                "refresh_token": response.session.refresh_token,
+                "expires_at": expires_at,
+                "expires_in_seconds": expiry_seconds
             }
         }
+    }
 
 
 async def refresh_user_token(authorization, refresh_token: str):
@@ -283,10 +288,10 @@ async def get_session_by_authorization(authorization):
         if user.user_metadata and 'role' in user.user_metadata:
             user_role = user.user_metadata['role']
         return {"user": {
-                     "id": user.id,
-                     "email": user.email,
-                     "role": user_role
-                 }
-             }
+            "id": user.id,
+            "email": user.email,
+            "role": user_role
+        }
+        }
     else:
         raise ValueError("Session is invalid")