particle-os/debian-koji
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fixes

Browse source
This commit is contained in:
Mike McLean 2023-04-11 22:51:25 -04:00 • committed by Tomas Kopecek
parent f54e4f6acb
commit 74fd761750
1 changed files with 5 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

11
kojihub/scheduler.py
View file

@ -122,16 +122,15 @@ class TaskScheduler(object):
# already running elsewhere
return False
self.get_tasks()
self.get_hosts()
self.check_hosts()
self.do_schedule()
self.check_active_tasks()
self.check_hosts()
return True
def do_schedule(self):
self.get_tasks()
self.get_hosts()
# debug
logger.info('Running task scheduler')
logger.info(f'Hosts: {len(self.hosts)}')
@ -169,8 +168,8 @@ class TaskScheduler(object):
task['_hosts'] = []
min_avail = min(0, task['weight'] - self.capacity_overcommit)
for host in self.hosts_by_bin.get(task['_bin'], []):
if (host['capacity'] - host['_load'] > min_avail and
host['_ntasks'] < self.maxjobs):
if (host['ready'] and host['_ntasks'] < self.maxjobs and
host['capacity'] - host['_load'] > min_avail):
task['_hosts'].append(host)
logger.info(f'Task {task["task_id"]}: {len(task["_hosts"])} options')
#import pdb; pdb.set_trace()