From 9a161f9146a5e7e4da398431a8aa52f1f8a44dd7 Mon Sep 17 00:00:00 2001 From: Mike McLean Date: Sun, 30 Mar 2025 22:11:53 -0400 Subject: [PATCH] fix min_avail calculation --- kojihub/scheduler.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/kojihub/scheduler.py b/kojihub/scheduler.py index c649827e..9f0757cd 100644 --- a/kojihub/scheduler.py +++ b/kojihub/scheduler.py @@ -377,7 +377,7 @@ class TaskScheduler(object): refusals = self.get_refusals() for task in self.free_tasks: task['_hosts'] = [] - min_avail = min(0, task['weight'] - self.capacity_overcommit) + min_avail = max(0, task['weight'] - self.capacity_overcommit) h_refused = refusals.get(task['task_id'], {}) for host in self.hosts_by_bin.get(task['_bin'], []): if (host['ready'] and @@ -402,7 +402,7 @@ class TaskScheduler(object): # tasks are already in priority order for task in self.free_tasks: - min_avail = task['weight'] - self.capacity_overcommit + min_avail = max(0, task['weight'] - self.capacity_overcommit) task['_hosts'].sort(key=lambda h: h['_rank']) logger.debug('Task %i choices: %s', task['task_id'], [(h['name'], "%(_rank).2f" % h) for h in task['_hosts']])