From 4641bdcb07a39a06e2e05e95fd50c05d673953bf Mon Sep 17 00:00:00 2001
From: cfdaily <cfdaily@gitee.com>
Date: Sun, 17 May 2026 13:47:47 +0800
Subject: [PATCH] auto-sync: 2026-05-17 13:47:47

---
 src/blackboard/queries.py | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/src/blackboard/queries.py b/src/blackboard/queries.py
index 2aee233..8e6029c 100644
--- a/src/blackboard/queries.py
+++ b/src/blackboard/queries.py
@@ -73,6 +73,18 @@ class Queries:
         finally:
             conn.close()
 
+    def tasks_by_status(self, status: str) -> List[Task]:
+        """查询指定状态的所有任务"""
+        conn = self._conn()
+        try:
+            rows = conn.execute(
+                "SELECT * FROM tasks WHERE status=? ORDER BY priority ASC",
+                (status,),
+            ).fetchall()
+            return [Task.from_row(r) for r in rows]
+        finally:
+            conn.close()
+
     def pending_dispatchable(self) -> List[Task]:
         """查询可调度的 pending 任务（依赖已满足）"""
         conn = self._conn()