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

track update time in host table

Browse source
This commit is contained in:
Mike McLean 2023-04-07 19:50:15 -04:00 • committed by Tomas Kopecek
parent 9321ffebec
commit d82edd9757
2 changed files with 11 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

1
docs/schema.sql
View file

@ -160,6 +160,7 @@ CREATE TABLE host (
id SERIAL NOT NULL PRIMARY KEY,
user_id INTEGER NOT NULL REFERENCES users (id),
name VARCHAR(128) UNIQUE NOT NULL,
update_time TIMESTAMPTZ,
task_load FLOAT CHECK (NOT task_load < 0) NOT NULL DEFAULT 0.0,
ready BOOLEAN NOT NULL DEFAULT 'false'
) WITHOUT OIDS;

15
kojihub/kojihub.py
View file

@ -5501,6 +5501,7 @@ def get_host(hostInfo, strict=False, event=None):
('host.id', 'id'),
('host.user_id', 'user_id'),
('host.name', 'name'),
("date_part('epoch', host.update_time)", 'update_ts'),
('host.ready', 'ready'),
('host.task_load', 'task_load'),
('host_config.arches', 'arches'),
@ -13288,6 +13289,7 @@ class RootExports(object):
('host.id', 'id'),
('host.user_id', 'user_id'),
('host.name', 'name'),
("date_part('epoch', host.update_time)", 'update_ts'),
('host.ready', 'ready'),
('host.task_load', 'task_load'),
('host_config.arches', 'arches'),
@ -14261,11 +14263,14 @@ class Host(object):
def updateHost(self, task_load, ready):
host_data = get_host(self.id)
task_load = float(task_load)
if task_load != host_data['task_load'] or ready != host_data['ready']:
update = UpdateProcessor('host', clauses=['id=%(id)i'], values={'id': self.id},
data={'task_load': task_load, 'ready': ready})
update.execute()
context.commit_pending = True
update = UpdateProcessor(
'host',
data={'task_load': task_load, 'ready': ready},
rawdata={'update_time': 'NOW()'},
clauses=['id=%(id)i'],
values={'id': self.id},
)
update.execute()
def getLoadData(self):
"""Get load balancing data