diff --git a/src/daemon/ticker.py b/src/daemon/ticker.py index 65f8a2a..ba589d5 100644 --- a/src/daemon/ticker.py +++ b/src/daemon/ticker.py @@ -1138,7 +1138,7 @@ Parent Task ID: {parent_task.id} for t in broadcastable: tracker = self._broadcast_tracker[t.id] unnotified = all_agent_ids - tracker.notified_agents - if not unnotified and tracker.responded_agents >= tracker.notified_agents: + if not unnotified and tracker.responded_agents == tracker.notified_agents: # 一轮结束 tracker.round_number += 1 tracker.notified_agents.clear()