auto-sync: 2026-05-17 21:42:55
This commit is contained in:
@@ -238,9 +238,11 @@ class Dispatcher:
|
||||
return "\n".join(parts)
|
||||
|
||||
def _record_routing(self, task: Task, decision: Dict[str, Any],
|
||||
outcome: str, detail: Optional[str]) -> None:
|
||||
outcome: str, detail: Optional[str],
|
||||
override_db_path: Optional[Path] = None) -> None:
|
||||
"""写路由审计日志到 routing_decisions 表"""
|
||||
if not self.db_path:
|
||||
effective_db = override_db_path or self.db_path
|
||||
if not effective_db:
|
||||
return
|
||||
try:
|
||||
conn = sqlite3.connect(str(self.db_path))
|
||||
|
||||
@@ -383,7 +383,7 @@ class Ticker:
|
||||
result = await self.dispatcher.dispatch(
|
||||
task,
|
||||
action_type="review",
|
||||
project_config={"project_id": project_id},
|
||||
project_config={"project_id": project_id, "db_path": db_path},
|
||||
)
|
||||
if result["status"] == "dispatched":
|
||||
dispatched.append(task.id)
|
||||
|
||||
Reference in New Issue
Block a user