auto-sync: 2026-06-05 13:29:53
This commit is contained in:
@@ -79,14 +79,15 @@ class TestNoReplyAddsResponded:
|
|||||||
assert "task-1" in ticker._broadcast_tracker # 未清理
|
assert "task-1" in ticker._broadcast_tracker # 未清理
|
||||||
|
|
||||||
def test_rejected_adds_agent(self):
|
def test_rejected_adds_agent(self):
|
||||||
"""B2 补充:'rejected' 也加入 responded"""
|
"""B2 补充:'rejected' 也加入 responded(多 agent 避免轮次结束清空)"""
|
||||||
ticker = _make_minimal_ticker()
|
ticker = _make_minimal_ticker()
|
||||||
tracker = _make_round("task-1", notified={"agent-a"})
|
tracker = _make_round("task-1", notified={"agent-a", "agent-b"})
|
||||||
ticker._broadcast_tracker["task-1"] = tracker
|
ticker._broadcast_tracker["task-1"] = tracker
|
||||||
|
|
||||||
ticker.record_broadcast_response("task-1", "agent-a", "rejected")
|
ticker.record_broadcast_response("task-1", "agent-a", "rejected")
|
||||||
|
|
||||||
assert "agent-a" in tracker.responded_agents
|
assert "agent-a" in tracker.responded_agents
|
||||||
|
assert tracker.round_number == 0 # 还没完成一轮
|
||||||
|
|
||||||
|
|
||||||
# ===================================================================
|
# ===================================================================
|
||||||
|
|||||||
Reference in New Issue
Block a user