auto-sync: 2026-05-17 13:47:47

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()