From 7d1f2d7c2fe5a2b42e2720955fadd2e3a4491c92 Mon Sep 17 00:00:00 2001
From: cfdaily <cfdaily@gitee.com>
Date: Tue, 28 Apr 2026 23:39:46 +0800
Subject: [PATCH] auto-sync: 2026-04-28 23:39:46

---
 auto-sync-cron.log                         |  4 ++++
 logs/auto-sync.log                         |  1 +
 scripts/backtest-service/result_storage.py | 16 ++++++++++++++++
 3 files changed, 21 insertions(+)

diff --git a/auto-sync-cron.log b/auto-sync-cron.log
index a7d8fcff..b89d4d2d 100644
--- a/auto-sync-cron.log
+++ b/auto-sync-cron.log
@@ -69125,3 +69125,7 @@ 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
+/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 630b693a..d61921f8 100644
--- a/logs/auto-sync.log
+++ b/logs/auto-sync.log
@@ -5529,5 +5529,6 @@
 
 
 
+
 
 
diff --git a/scripts/backtest-service/result_storage.py b/scripts/backtest-service/result_storage.py
index e8cc1903..b8be34ea 100755
--- a/scripts/backtest-service/result_storage.py
+++ b/scripts/backtest-service/result_storage.py
@@ -77,6 +77,22 @@ class ResultStorage:
         
         return BacktestResult(**data)
     
+    def find_task(self, task_id: str) -> Optional[BacktestTaskWithId]:
+        """在所有状态目录中查找任务"""
+        for status_dir in ["running", "failed", "completed", "pending"]:
+            task = self.load_task(task_id, status_dir)
+            if task:
+                return task
+        return None
+
+    def find_result(self, task_id: str) -> Optional[BacktestResult]:
+        """在所有状态目录中查找结果"""
+        for status_dir in ["failed", "completed", "running", "pending"]:
+            result = self.load_result(task_id, status_dir)
+            if result:
+                return result
+        return None
+
     def get_task_path(self, task_id: str, status: str, filename: str) -> str:
         """获取任务文件路径"""
         return os.path.join(self._task_dir(task_id, status), filename)