From 4c83a7ccd7c57bc4738df0577480d1146a729b14 Mon Sep 17 00:00:00 2001 From: cfdaily Date: Sun, 17 May 2026 21:43:36 +0800 Subject: [PATCH] auto-sync: 2026-05-17 21:43:36 --- src/daemon/dispatcher.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/daemon/dispatcher.py b/src/daemon/dispatcher.py index 8606850..95a4745 100644 --- a/src/daemon/dispatcher.py +++ b/src/daemon/dispatcher.py @@ -129,7 +129,7 @@ class Dispatcher: # 检查并发限制 if self.counter and level in (DispatchLevel.FULL_AGENT, DispatchLevel.ESCALATE): if not await self.counter.can_acquire(agent_id): - self._record_routing(task, decision, "skipped", "Agent busy") + self._record_routing(task, decision, "skipped", "Agent busy", _routing_db) return { "level": level.value, "agent_id": agent_id, @@ -140,7 +140,7 @@ class Dispatcher: # 本地执行 if level == DispatchLevel.LOCAL: - self._record_routing(task, decision, "dispatched", None) + self._record_routing(task, decision, "dispatched", None, _routing_db) return { "level": level.value, "agent_id": "daemon", @@ -152,7 +152,7 @@ class Dispatcher: # Full Agent / Escalate spawn if level in (DispatchLevel.FULL_AGENT, DispatchLevel.ESCALATE): if not self.spawner: - self._record_routing(task, decision, "error", "No spawner") + self._record_routing(task, decision, "error", "No spawner", _routing_db) return { "level": level.value, "agent_id": agent_id, @@ -176,7 +176,7 @@ class Dispatcher: ) self._record_routing(task, decision, "dispatched", - f"session={session_id}") + f"session={session_id}", _routing_db) return { "level": level.value, @@ -188,7 +188,7 @@ class Dispatcher: except Exception as e: if self.counter: self.counter.release(agent_id) - self._record_routing(task, decision, "error", str(e)) + self._record_routing(task, decision, "error", str(e), _routing_db) return { "level": level.value, "agent_id": agent_id,