feat: Locust multi-process

Author: LuckyYC

backend/service/analysis_service.py

@@ -67,7 +67,7 @@ async def analyze_tasks_svc(
         try:
             ai_config = await get_ai_service_config_internal_svc(request)
         except HTTPException as e:
-            error_msg = f"Failed to get AI service configuration. {str(e)}"
+            error_msg = "Failed to get AI service configuration. %s" % str(e)
             logger.error(error_msg, exc_info=True)
             return AnalysisResponse(
                 task_ids=task_ids,
@@ -201,8 +201,9 @@ async def analyze_tasks_svc(
 
     except Exception as e:
         # Handle other exceptions - only log error, don't update database
-        error_message = (
-            f"Analysis failed for tasks {analysis_request.task_ids}: {str(e)}"
+        error_message = "Analysis failed for tasks %s: %s" % (
+            analysis_request.task_ids,
+            str(e),
         )
         logger.error(error_message, exc_info=True)
         return AnalysisResponse(
@@ -268,7 +269,7 @@ async def get_analysis_svc(request: Request, task_id: str) -> GetAnalysisRespons
         )
 
     except Exception as e:
-        error_msg = f"Failed to retrieve analysis for task {task_id}: {str(e)}"
+        error_msg = "Failed to retrieve analysis for task %s: %s" % (task_id, str(e))
         logger.error(error_msg, exc_info=True)
         return GetAnalysisResponse(
             data=None,
@@ -322,18 +323,18 @@ async def _call_ai_service(
             model_info_str = json.dumps(model_info, ensure_ascii=False, indent=2)
             prompt = prompt_template.format(model_info=model_info_str)
         except (TypeError, ValueError) as e:
-            error_msg = f"Failed to serialize model_info: {str(e)}"
+            error_msg = "Failed to serialize model_info: %s" % str(e)
             logger.error(error_msg)
             # Try fallback serialization
             try:
                 model_info_str = str(model_info)
                 prompt = prompt_template.format(model_info=model_info_str)
             except Exception as fallback_error:
-                logger.error(f"Fallback serialization failed: {str(fallback_error)}")
-                raise Exception(f"Failed to serialize model_info: {str(e)}")
+                logger.error("Fallback serialization failed: %s" % str(fallback_error))
+                raise Exception("Failed to serialize model_info: %s" % str(e))
         except Exception as format_error:
-            error_msg = f"Failed to format prompt: {str(format_error)}"
-            logger.error(f"Prompt formatting error: {error_msg}")
+            error_msg = "Failed to format prompt: %s" % str(format_error)
+            logger.error("Prompt formatting error: %s" % error_msg)
             raise Exception(error_msg)
     else:
         error_msg = "model_info is required for task analysis"
@@ -372,22 +373,22 @@ async def _call_ai_service(
             raise Exception(error_msg)
 
     except httpx.TimeoutException as e:
-        error_msg = f"AI service request timeout: {str(e)}"
-        logger.error(f"AI service timeout error: {error_msg}")
+        error_msg = "AI service request timeout: %s" % str(e)
+        logger.error("AI service timeout error: %s" % error_msg)
         raise Exception(error_msg)
     except httpx.ConnectError as e:
-        error_msg = f"AI service connection error: {str(e)}"
-        logger.error(f"AI service connection error: {error_msg}")
+        error_msg = "AI service connection error: %s" % str(e)
+        logger.error("AI service connection error: %s" % error_msg)
         raise Exception(error_msg)
     except httpx.HTTPStatusError as e:
-        error_msg = f"AI service HTTP error: {e.response.status_code} - {str(e)}"
-        logger.error(f"AI service HTTP error: {error_msg}")
+        error_msg = "AI service HTTP error: %s - %s" % (e.response.status_code, str(e))
+        logger.error("AI service HTTP error: %s" % error_msg)
         raise Exception(error_msg)
     except httpx.RequestError as e:
-        error_msg = f"AI service request failed: {str(e)}"
-        logger.error(f"AI service request error: {error_msg}")
+        error_msg = "AI service request failed: %s" % str(e)
+        logger.error("AI service request error: %s" % error_msg)
         raise Exception(error_msg)
     except Exception as e:
-        error_msg = f"AI service call failed: {str(e)}"
-        logger.error(f"AI service general error: {error_msg}")
+        error_msg = "AI service call failed: %s" % str(e)
+        logger.error("AI service general error: %s" % error_msg)
         raise Exception(error_msg)

backend/service/log_service.py

@@ -98,7 +98,7 @@ def get_last_n_lines(file_path: str, n: int = 100) -> str:
             return result
 
     except Exception as e:
-        logger.error(f"Failed to read log file: {str(e)}")
+        logger.error("Failed to read log file: %s" % str(e))
         return ""
 
 
@@ -155,7 +155,7 @@ async def get_service_log_svc(service_name: str, offset: int, tail: int):
         file_size = os.path.getsize(log_file_path)
         return LogContentResponse(content=content, file_size=file_size)
     except Exception as e:
-        logger.error(f"Failed to read log file {log_file_path}: {str(e)}")
+        logger.error("Failed to read log file %s: %s" % (log_file_path, str(e)))
         return ErrorResponse.internal_server_error(ErrorMessages.LOG_FILE_READ_FAILED)
 
 
@@ -182,5 +182,5 @@ async def get_task_log_svc(task_id: str, offset: int, tail: int):
         file_size = os.path.getsize(log_file_path)
         return LogContentResponse(content=content, file_size=file_size)
     except Exception as e:
-        logger.error(f"Failed to read log file {log_file_path}: {str(e)}")
+        logger.error("Failed to read log file %s: %s" % (log_file_path, str(e)))
         return ErrorResponse.internal_server_error(ErrorMessages.LOG_FILE_READ_FAILED)

backend/service/system_service.py

@@ -77,7 +77,7 @@ async def get_system_configs_svc(request: Request) -> SystemConfigListResponse:
         )
 
     except Exception as e:
-        logger.warning(f"Failed to get system configs: {str(e)}")
+        logger.warning("Failed to get system configs: %s" % str(e))
         return SystemConfigListResponse(
             data=[],
             status="success",
@@ -135,7 +135,7 @@ async def get_system_configs_internal_svc(request: Request) -> SystemConfigListR
         )
 
     except Exception as e:
-        logger.error(f"Failed to get system configs: {str(e)}")
+        logger.error("Failed to get system configs: %s" % str(e))
         return SystemConfigListResponse(
             data=[],
             status="error",
@@ -207,7 +207,7 @@ async def create_system_config_svc(
     except HTTPException:
         raise
     except Exception as e:
-        logger.error(f"Failed to create system config: {str(e)}")
+        logger.error("Failed to create system config: %s" % str(e))
         raise HTTPException(status_code=500, detail=ErrorMessages.TASK_CREATION_FAILED)
 
 
@@ -269,7 +269,7 @@ async def update_system_config_svc(
     except HTTPException:
         raise
     except Exception as e:
-        logger.error(f"Failed to update system config: {str(e)}")
+        logger.error("Failed to update system config: %s" % str(e))
         raise HTTPException(status_code=500, detail=ErrorMessages.TASK_UPDATE_FAILED)
 
 
@@ -307,7 +307,7 @@ async def delete_system_config_svc(request: Request, config_key: str) -> Dict:
     except HTTPException:
         raise
     except Exception as e:
-        logger.error(f"Failed to delete system config: {str(e)}")
+        logger.error("Failed to delete system config: %s" % str(e))
         raise HTTPException(status_code=500, detail=ErrorMessages.TASK_DELETION_FAILED)
 
 
@@ -368,7 +368,7 @@ async def get_ai_service_config_svc(request: Request) -> AIServiceConfig:
     except HTTPException:
         raise
     except Exception as e:
-        logger.error(f"Failed to get AI service config: {str(e)}")
+        logger.error("Failed to get AI service config: %s" % str(e))
         raise HTTPException(status_code=500, detail=ErrorMessages.DATABASE_ERROR)
 
 
@@ -428,7 +428,7 @@ async def get_ai_service_config_internal_svc(request: Request) -> AIServiceConfi
     except HTTPException:
         raise
     except Exception as e:
-        logger.error(f"Failed to get AI service config: {str(e)}")
+        logger.error("Failed to get AI service config: %s" % str(e))
         raise HTTPException(status_code=500, detail=ErrorMessages.DATABASE_ERROR)
 
 
@@ -520,7 +520,7 @@ async def batch_upsert_system_configs_svc(
         )
 
     except Exception as e:
-        logger.error(f"Failed to batch upsert system configs: {str(e)}")
+        logger.error("Failed to batch upsert system configs: %s" % str(e))
         return BatchSystemConfigResponse(
             data=[],
             status="error",

backend/service/task_service.py

@@ -288,7 +288,7 @@ async def stop_task_svc(request: Request, task_id: str):
             status="stopping", task_id=task_id, message="Task is being stopped."
         )
     except Exception as e:
-        logger.error(f"Failed to stop task {task_id}: {str(e)}", exc_info=True)
+        logger.error("Failed to stop task %s: %s" % (task_id, str(e)), exc_info=True)
         return TaskCreateRsp(
             status="error", task_id=task_id, message="Failed to stop task."
         )
@@ -306,7 +306,7 @@ async def create_task_svc(request: Request, body: TaskCreateReq):
         A `TaskCreateRsp` on success or a `JSONResponse` on failure.
     """
     task_id = str(uuid.uuid4())
-    logger.info(f"Creating task '{body.name}' with ID: {task_id}")
+    logger.info("Creating task '%s' with ID: %s" % (body.name, task_id))
 
     cert_file, key_file = _get_cert_config(body)
 
@@ -363,7 +363,7 @@ async def create_task_svc(request: Request, body: TaskCreateReq):
         db.add(new_task)
         await db.flush()
         await db.commit()
-        logger.info(f"Task created successfully: {new_task.id}")
+        logger.info("Task created successfully: %s" % new_task.id)
 
         return TaskCreateRsp(
             task_id=str(new_task.id),
@@ -372,7 +372,7 @@ async def create_task_svc(request: Request, body: TaskCreateReq):
         )
     except Exception as e:
         await db.rollback()
-        error_msg = f"Failed to create task in database: {str(e)}"
+        error_msg = "Failed to create task in database: %s" % str(e)
         logger.error(error_msg, exc_info=True)
         return ErrorResponse.internal_server_error(error_msg)
 
@@ -431,7 +431,7 @@ async def is_task_exist(request: Request, task_id: str) -> bool:
         return result.scalar_one_or_none() is not None
     except Exception as e:
         logger.error(
-            f"Failed to query for task existence (id={task_id}): {str(e)}",
+            "Failed to query for task existence (id=%s): %s" % (task_id, str(e)),
             exc_info=True,
         )
         return False
@@ -516,7 +516,9 @@ async def get_task_svc(request: Request, task_id: str):
         # Re-raise HTTPException to let FastAPI handle it.
         raise
     except Exception as e:
-        logger.error(f"Failed to retrieve task {task_id}: {str(e)}", exc_info=True)
+        logger.error(
+            "Failed to retrieve task %s: %s" % (task_id, str(e)), exc_info=True
+        )
         raise HTTPException(
             status_code=500,
             detail="An internal error occurred while retrieving the task.",
@@ -563,7 +565,7 @@ async def get_task_status_svc(request: Request, task_id: str):
         raise
     except Exception as e:
         logger.error(
-            f"Failed to retrieve task status {task_id}: {str(e)}", exc_info=True
+            "Failed to retrieve task status %s: %s" % (task_id, str(e)), exc_info=True
         )
         raise HTTPException(
             status_code=500,
@@ -624,7 +626,7 @@ async def get_model_tasks_for_comparison_svc(request: Request):
 
     except Exception as e:
         logger.error(
-            f"Failed to get model tasks for comparison: {str(e)}", exc_info=True
+            "Failed to get model tasks for comparison: %s" % str(e), exc_info=True
         )
         return ModelTasksResponse(
             data=[],
@@ -697,7 +699,8 @@ async def compare_performance_svc(
 
         # Log metrics extraction results for debugging
         logger.info(
-            f"Extracted metrics for {len(metrics_data_list)} out of {len(task_ids)} tasks"
+            "Extracted metrics for %s out of %s tasks"
+            % (len(metrics_data_list), len(task_ids))
         )
 
         # Check if we have any valid metrics
@@ -736,7 +739,8 @@ async def compare_performance_svc(
                     comparison_metrics.append(metrics)
                 except Exception as e:
                     logger.error(
-                        f"Failed to create ComparisonMetrics for task {metrics_data.get('task_id', 'unknown')}: {str(e)}"
+                        "Failed to create ComparisonMetrics for task %s: %s"
+                        % (metrics_data.get("task_id", "unknown"), str(e))
                     )
                     continue
 
@@ -750,7 +754,7 @@ async def compare_performance_svc(
         return ComparisonResponse(data=comparison_metrics, status="success", error=None)
 
     except Exception as e:
-        logger.error(f"Failed to compare performance: {str(e)}", exc_info=True)
+        logger.error("Failed to compare performance: %s" % str(e), exc_info=True)
         return ComparisonResponse(
             data=[], status="error", error="Failed to perform performance comparison"
         )
@@ -812,7 +816,7 @@ def _prepare_request_payload(body: TaskCreateReq) -> Dict:
             try:
                 return json.loads(body.request_payload)
             except json.JSONDecodeError as e:
-                raise ValueError(f"Invalid JSON in request payload: {str(e)}")
+                raise ValueError("Invalid JSON in request payload: %s" % str(e))
         else:
             raise ValueError("Request payload is required for custom API endpoints")
 
@@ -885,7 +889,7 @@ def _read(path: str) -> str:
 
         return True, ""
     except Exception as e:
-        return False, f"Certificate validation error: {str(e)}"
+        return False, "Certificate validation error: %s" % str(e)
 
 
 def _prepare_client_cert(body: TaskCreateReq):
@@ -900,7 +904,7 @@ def _prepare_client_cert(body: TaskCreateReq):
         try:
             is_valid, err_msg = _validate_certificate_files(cert_file, key_file or None)
             if not is_valid:
-                logger.error(f"Invalid client certificate configuration: {err_msg}")
+                logger.error("Invalid client certificate configuration: %s" % err_msg)
                 return None
 
             if cert_file and key_file:
@@ -910,7 +914,7 @@ def _prepare_client_cert(body: TaskCreateReq):
                 # Only cert file provided (combined cert+key file)
                 client_cert = cert_file
         except Exception as e:
-            logger.error(f"Error preparing certificate configuration: {e}")
+            logger.error("Error preparing certificate configuration: %s" % str(e))
             return None
 
     return client_cert
@@ -1029,14 +1033,14 @@ async def test_api_endpoint_svc(request: Request, body: TaskCreateReq):
         logger.error("Request timeout when testing API endpoint.")
         return {
             "status": "error",
-            "error": f"Request timeout: {str(e)}",
+            "error": "Request timeout: %s" % str(e),
             "response": None,
         }
     except httpx.ConnectError as e:
         logger.error("Connection error when testing API endpoint.")
         return {
             "status": "error",
-            "error": f"Connection error: {str(e)}",
+            "error": "Connection error: %s" % str(e),
             "response": None,
         }
     except asyncio.TimeoutError:
@@ -1047,10 +1051,10 @@ async def test_api_endpoint_svc(request: Request, body: TaskCreateReq):
             "response": None,
         }
     except Exception as e:
-        logger.error(f"Error testing API endpoint: {e}", exc_info=True)
+        logger.error("Error testing API endpoint: %s" % str(e), exc_info=True)
         return {
             "status": "error",
-            "error": f"Unexpected error: {str(e)}",
+            "error": "Unexpected error: %s" % str(e),
             "response": None,
         }
 
@@ -1149,11 +1153,11 @@ async def _handle_streaming_response(response, full_url: str) -> Dict:
         }
     except Exception as stream_error:
         logger.error(
-            f"Error processing stream: {stream_error}. stream data: {stream_data}"
+            "Error processing stream: %s. stream data: %s" % (stream_error, stream_data)
         )
         return {
             "status": "error",
-            "error": f"Streaming data processing error: {str(stream_error)}",
+            "error": "Streaming data processing error: %s" % str(stream_error),
             "response": {
                 "status_code": (
                     response.status_code if hasattr(response, "status_code") else None

backend/utils/tools.py

@@ -44,7 +44,7 @@ def mask_sensitive_data(data: Union[dict, list]) -> Union[dict, list]:
                 else:
                     safe_dict[key] = mask_sensitive_data(value)
         except Exception as e:
-            logger.warning(f"Error masking sensitive data: {str(e)}")
+            logger.warning("Error masking sensitive data: %s" % str(e))
             return data
         return safe_dict
     elif isinstance(data, list):
@@ -259,7 +259,8 @@ async def extract_task_metrics(
 
     except Exception as e:
         logger.error(
-            f"Failed to extract metrics for task {task_id}: {str(e)}", exc_info=True
+            "Failed to extract metrics for task %s: %s" % (task_id, str(e)),
+            exc_info=True,
         )
         return None