diff --git a/main/lib/idds/agents/coordinator/coordinator.py b/main/lib/idds/agents/coordinator/coordinator.py index 8a12a230..55c0d3ba 100644 --- a/main/lib/idds/agents/coordinator/coordinator.py +++ b/main/lib/idds/agents/coordinator/coordinator.py @@ -58,7 +58,7 @@ def __init__(self, num_threads=1, coordination_interval_delay=300, else: self.interval_delay = 30 self.max_boost_interval_delay = int(max_boost_interval_delay) - self.max_queued_events = max_queued_events + self.min_queued_events = min_queued_events if self.min_queued_events: self.min_queued_events = int(self.min_queued_events) else: