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

auto-sync: 2026-05-17 21:43:36

Browse Source
This commit is contained in:
cfdaily
2026-05-17 21:43:36 +08:00
parent de9caadff8
commit 4c83a7ccd7
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/daemon/dispatcher.py
+5 -5
View File
@@ -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,