From d20cb243e018e0cbdadb3a3f33e62e0cdea2c823 Mon Sep 17 00:00:00 2001 From: cfdaily Date: Mon, 18 May 2026 00:29:24 +0800 Subject: [PATCH] auto-sync: 2026-05-18 00:29:24 --- src/daemon/ticker.py | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/src/daemon/ticker.py b/src/daemon/ticker.py index 527c6da..5ff9053 100644 --- a/src/daemon/ticker.py +++ b/src/daemon/ticker.py @@ -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: