update locust version and support FastHttpUser

Author: LuckyYC

backend/service/analysis_service.py

@@ -235,7 +235,7 @@ async def get_analysis_svc(request: Request, task_id: str) -> GetAnalysisRespons
         analysis = analysis_result.scalar_one_or_none()
 
         if not analysis:
-            logger.warning(f"Analysis not found for task: {task_id}")
+            # logger.warning(f"Analysis not found for task: {task_id}")
             return GetAnalysisResponse(
                 data=None,
                 status="not_found",

backend/utils/prompt.py

@@ -14,17 +14,17 @@
     [1–3 sentence overall assessment, including UX judgment and the dominant bottleneck(s).]
 
     ### Key Metrics
-    | Metric | Value(avg/max) | Threshold/Target | Verdict |
+    | Metric | Description |Value(avg/max)| Verdict |
     |---|---|---|---|
-    | Concurrent_users | N | — | — |
-    | First_token_latency(s) | X.XX | Good (<1.00s), Moderate (1.00–2.00s), Poor (>2.00s) | Good/Moderate/Poor |
-    | Total_time(s) | X.XX | Good (<60.00s), Moderate (60.00–180.00s), Poor (>180.00s) | Good/Moderate/Poor |
-    | RPS(req/s) | X.XX | — | — |
-    | Completion Tps(Tokens/s) | X.XX | — | — |
-    | Total Tps(Tokens/s) | X.XX | — | — |
-    | Avg_completion_tokens(Tokens/req) | N | — | — |
-    | Avg_total_tokens(Tokens/req) | N | — | — |
-    |Failure_request| N | — | — |
+    | Concurrent_users |Number of simultaneous users accessing the system	| N | — |
+    | First_token_latency(s) |Time taken to receive the first token in response| X.XX | Good/Moderate/Poor |
+    | Total_time(s) |Total time taken to complete all requests| X.XX | Good/Moderate/Poor |
+    | RPS |Requests processed per second | X.XX | — |
+    | Completion_tps |Tokens generated per second for completion only| X.XX | — |
+    | Total_tps|Total tokens processed per second (including prompt and completion)| X.XX | — |
+    | Avg_completion_tokens/req |Average number of completion tokens per request| X.XX | — |
+    | Avg_total_tokens/req |Average total tokens (prompt + completion) per request| X.XX | — |
+    | Failure_request|Number of failed requests| N | — |
 
     ### Identified Issues
     1. [Most critical issue with metric value and impact, if any]
@@ -37,7 +37,7 @@
     规则：
     - First_token_latency 评估：良好（<1.00 秒），中等（1.00-2.00 秒），较差（>2.00 秒）。
     - Total_time 评估：良好（<60.00 秒），中等（60.00-180.00 秒），较差（>180.00 秒）。
-    - 如果 Total_time 为“较差”，请重点说明和分析 First_token_latency、Total_tps 和 Avg_total_tokens 对 Total_time 的影响。
+    - 如果 Total_time 为“较差”，请重点说明和分析 First_token_latency、Total_tps 和 Avg_total_tokens/req 对 Total_time 的影响。
     - Failure_request：如果存在失败的请求，请在“已识别问题”中指出。
     - 如果缺少某个指标，则显示 N/A（不推断）。
     - 输出内容应控制在 300 字以内，技术性强，并优先处理最严重的问题。
@@ -47,19 +47,19 @@
     [1-3 句总体评估，包括用户体验判断和主要瓶颈。]
 
     ### 关键指标
-    | 指标 | 值（平均值/最大值） | 阈值/目标 | 结论 |
+    | 指标 |描述| 值（平均值/最大值）| 结论 |
     |---|---|---|---|
-    | 并发用户数 | N | — | — |
-    | 首Token时延 (s) | X.XX | 良好 (<1.00 秒)、中等 (1.00-2.00 秒)、较差 (>2.00 秒) | 良好/中等/较差 |
-    | 总时间 (s) | X.XX | 良好 (<60.00 秒)、中等 (60.00-180.00 秒)、较差 (>180.00 秒) | 良好/中等/较差 |
-    | RPS（请求/秒）| X.XX | — | — |
-    | Completion Tokens 吞吐量（Tokens/秒）| X.XX | — | — |
-    | Total Tokens 吞吐量（Tokens/秒）| X.XX | — | — |
-    | 平均每请求输出Token数量（Tokens/请求）| N | — | — |
-    | 平均每请求总Token数量（Tokens/请求）| N | — | — |
-    | 失败请求| N | — | — |
+    | Concurrent_users | 同时访问系统的用户数 | N | — |
+    | First_token_latency(s) | 接收第一个token所需的时间| X.XX | 好/中等/差 |
+    | Total_time(s) | 完成所有请求所需的总时间| X.XX | 好/中等/差 |
+    | RPS | 每秒处理的请求数| X.XX | — |
+    | Completion_tps | 每秒输出生成的token数| X.XX | — |
+    | Total_tps| 每秒输入和输出总token总数| X.XX | — |
+    | Avg_completion_tokens/req | 每个请求的平均输出token数| X.XX | — |
+    | Avg_total_tokens/req |每个请求的平均输入和输出token总数| X.XX | — |
+    | Failure_request|失败请求数| N | — |
 
-    ### 已识别的问题
+    ### 问题总结
     1. [具有指标值和影响的最关键问题（如果有）]
     2. [重点说明是否存在失败请求，并指引用户查看任务日志以获取具体的错误信息（如果有）]
     """

frontend/public/locales/zh/translation.json

@@ -1,7 +1,7 @@
 {
   "sidebar": {
     "testTasks": "测试任务",
-    "modelArena": "模型竞技场",
+    "modelArena": "模型擂台",
     "monitorHub": "监控中心",
     "systemConfig": "系统配置"
   },

st_engine/engine/core.py

@@ -9,6 +9,8 @@
 from dataclasses import dataclass, field
 from typing import Dict, Optional, Tuple, Union
 
+from gevent import queue
+
 from utils.config import DEFAULT_API_PATH, DEFAULT_CONTENT_TYPE
 
 
@@ -40,6 +42,7 @@ class GlobalConfig:
     request_payload: Optional[str] = None
     model_name: Optional[str] = None
     system_prompt: Optional[str] = None
+    user_prompt: Optional[str] = None
     stream_mode: bool = True
     chat_type: int = 0
     cert_file: Optional[str] = None
@@ -63,6 +66,49 @@ class FieldMapping:
     prompt: str = ""
 
 
+# === GLOBAL STATE MANAGEMENT ===
+class GlobalStateManager:
+    """Manages global state for Locust testing."""
+
+    _global_config: Optional[GlobalConfig] = None
+    _global_task_queue: Optional[Dict[str, queue.Queue]] = None
+    _start_time: Optional[float] = None
+
+    @classmethod
+    def initialize_global_state(cls) -> None:
+        """Initialize global state."""
+        cls._global_config = GlobalConfig()
+        cls._global_task_queue = {
+            "completion_tokens_queue": queue.Queue(),
+            "all_tokens_queue": queue.Queue(),
+        }
+        cls._start_time = None
+
+    @classmethod
+    def get_global_config(cls) -> GlobalConfig:
+        """Thread-safe access to global configuration."""
+        if cls._global_config is None:
+            cls.initialize_global_state()
+        return cls._global_config  # type: ignore
+
+    @classmethod
+    def get_global_task_queue(cls) -> Dict[str, queue.Queue]:
+        """Thread-safe access to global task queue."""
+        if cls._global_task_queue is None:
+            cls.initialize_global_state()
+        return cls._global_task_queue  # type: ignore
+
+    @classmethod
+    def set_start_time(cls, start_time: float) -> None:
+        """Set the test start time."""
+        cls._start_time = start_time
+
+    @classmethod
+    def get_start_time(cls) -> Optional[float]:
+        """Get the test start time."""
+        return cls._start_time
+
+
 # === CONFIGURATION MANAGEMENT ===
 class ConfigManager:
     """Manages configuration parsing and validation."""
@@ -177,8 +223,8 @@ def configure_certificates(
             return (cert_file, key_file)
 
         if not cert_file and key_file:
-            # Key file without certificate file is invalid
-            raise ValueError("Key file provided without certificate file")
+            # Key file without certificate file is invalid, but don't fail
+            return None
 
         return None