...

kojihub/scheduler.py

@@ -136,6 +136,7 @@ class TaskScheduler(object):
             # already ran too recently
             return False
 
+        logger.info('Running task scheduler')
         self.get_tasks()
         self.get_hosts()
         self.check_hosts()
@@ -193,7 +194,6 @@ class TaskScheduler(object):
 
     def do_schedule(self):
         # debug
-        logger.info('Running task scheduler')
         logger.info(f'Hosts: {len(self.hosts)}')
         logger.info(f'Free tasks: {len(self.free_tasks)}')
         logger.info(f'Active tasks: {len(self.active_tasks)}')

schemas/schema.sql

@@ -1027,6 +1027,16 @@ CREATE TABLE scheduler_map (
 ) WITHOUT OIDS;
 
 
+CREATE TABLE scheduler_task_refusals (
+        id SERIAL NOT NULL PRIMARY KEY,
+        task_id INTEGER REFERENCES task (id) NOT NULL,
+        host_id INTEGER REFERENCES host (id) NOT NULL,
+        by_host BOOLEAN NOT NULL,
+        msg TEXT,
+        time TIMESTAMPTZ NOT NULL DEFAULT NOW()
+) WITHOUT OIDS;
+
+
 CREATE TABLE scheduler_log_messages (
         id SERIAL NOT NULL PRIMARY KEY,
         task_id INTEGER REFERENCES task (id),