From 718fc1445c9d297a112f8c74beab0b4055998c6c Mon Sep 17 00:00:00 2001
From: cfdaily <cfdaily@gitee.com>
Date: Tue, 28 Apr 2026 23:41:37 +0800
Subject: [PATCH] auto-sync: 2026-04-28 23:41:37

---
 auto-sync-cron.log              |  1 +
 logs/auto-sync.log              |  1 +
 scripts/backtest-service/api.py | 24 +++++++++---------------
 3 files changed, 11 insertions(+), 15 deletions(-)

diff --git a/auto-sync-cron.log b/auto-sync-cron.log
index b89d4d2d..494bea24 100644
--- a/auto-sync-cron.log
+++ b/auto-sync-cron.log
@@ -69129,3 +69129,4 @@ fatal: refusing to merge unrelated histories
 /bin/sh: ./management/sanguo_auto_sync/auto-sync.sh: No such file or directory
 /bin/sh: ./management/sanguo_auto_sync/auto-sync.sh: No such file or directory
 /bin/sh: ./management/sanguo_auto_sync/auto-sync.sh: No such file or directory
+/bin/sh: ./management/sanguo_auto_sync/auto-sync.sh: No such file or directory
diff --git a/logs/auto-sync.log b/logs/auto-sync.log
index d61921f8..fc9d4100 100644
--- a/logs/auto-sync.log
+++ b/logs/auto-sync.log
@@ -5530,5 +5530,6 @@
 
 
 
+
 
 
diff --git a/scripts/backtest-service/api.py b/scripts/backtest-service/api.py
index 7faebddd..9619b488 100755
--- a/scripts/backtest-service/api.py
+++ b/scripts/backtest-service/api.py
@@ -49,8 +49,8 @@ def list_tasks(
 
 @router.get("/status/{task_id}", summary="查询任务状态")
 def get_status(task_id: str) -> ApiResponse[Optional[BacktestTaskWithId]]:
-    """查询单个任务状态"""
-    task = task_queue.get_task(task_id)
+    """查询单个任务状态（从磁盘查找）"""
+    task = storage.find_task(task_id)
     if not task:
         return ApiResponse(code=404, msg="任务不存在", data=None)
     return ApiResponse(code=0, msg="success", data=task)
@@ -58,19 +58,13 @@ def get_status(task_id: str) -> ApiResponse[Optional[BacktestTaskWithId]]:
 
 @router.get("/result/{task_id}", summary="获取回测结果")
 def get_result(task_id: str) -> ApiResponse[Optional[BacktestResult]]:
-    """获取回测完整结果"""
-    task = task_queue.get_task(task_id)
-    if not task:
-        return ApiResponse(code=404, msg="任务不存在", data=None)
-    
-    # 根据状态找结果
-    if task.status == TaskStatus.COMPLETED:
-        result = storage.load_result(task_id, "completed")
-    elif task.status == TaskStatus.FAILED:
-        result = storage.load_result(task_id, "failed")
-    else:
-        result = None
-    
+    """获取回测完整结果（从磁盘查找）"""
+    result = storage.find_result(task_id)
+    if not result:
+        task = storage.find_task(task_id)
+        if not task:
+            return ApiResponse(code=404, msg="任务不存在", data=None)
+        return ApiResponse(code=0, msg="任务尚未完成", data=None)
     return ApiResponse(code=0, msg="success", data=result)