sanguo/sanguo_moziplus_v2
8
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

auto-sync: 2026-05-18 00:29:24

Browse Source
This commit is contained in:
cfdaily
2026-05-18 00:29:24 +08:00
parent 8068ce0267
commit d20cb243e0
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/daemon/ticker.py
+8 -6
View File
@@ -336,10 +336,11 @@ class Ticker:
# ------------------------------------------------------------------
async def _dispatch_pending(self, db_path: Path,
project_id: str) -> List[str]:
"""扫描 pending 任务并调度"""
project_id: str,
card_id: Optional[str] = None) -> List[str]:
"""扫描 pending 任务并调度（可按 card_id 过滤）"""
queries = Queries(db_path)
pending = queries.tasks_by_status("pending")
pending = queries.pending_dispatchable(card_id=card_id)
dispatched: List[str] = []
if not pending:
@@ -380,11 +381,12 @@ class Ticker:
return dispatched
async def _dispatch_reviews(self, db_path: Path,
project_id: str) -> List[str]:
"""扫描 review 状态任务，检查是否有产出，调度审查 Agent"""
project_id: str,
card_id: Optional[str] = None) -> List[str]:
"""扫描 review 状态任务，检查是否有产出，调度审查 Agent（可按 card_id 过滤）"""
queries = Queries(db_path)
bb = Blackboard(db_path)
review_tasks = queries.tasks_by_status("review")
review_tasks = queries.tasks_by_status("review", card_id=card_id)
dispatched: List[str] = []
for task in review_tasks: