auto-sync: 2026-04-28 23:41:37

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

logs/auto-sync.log

@@ -5530,5 +5530,6 @@
 
 
 
+
 
 

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)