PR#4031: Basic host data for scheduler - koji

Tomas Kopecek • a year ago

ed63d14

Tomas Kopecek • a year ago

3bbec5f

koji/daemon.py

file modified

+13

		`@@ -24,6 +24,7 @@`

		`import errno`
		`import hashlib`
		`+ import json`
		`import logging`
		`import os`
		`import re`
		`@@ -1025,9 +1026,21 @@`
		`else:`
		`self.logger.info("Lingering task %r (pid %r)" % (id, pid))`

		`+ def _get_host_data(self):`
		`+ data = {`
		`+ 'methods': list(self.handlers.keys()),`
		`+ 'maxjobs': self.options.maxjobs,`
		`+ # TODO: now it would be duplicated by updateHost`
		`+ #'ready': self.ready,`
		`+ #'task_load': self.task_load,`
		`+ #cpu_load, free_mem, free_disk, ...`
		`+ }`
		`+ return data`
		`+`
		`def getNextTask(self):`
		`self.ready = self.readyForTask()`
		`self.session.host.updateHost(self.task_load, self.ready)`
		`+ self.session.host.setHostData(json.dumps(self._get_host_data()))`
		`if not self.ready:`
		`self.logger.info("Not ready for task")`
		`return False`