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

bugfixes and additional debug logging

Browse source
This commit is contained in:
Mike McLean 2023-04-25 09:54:53 -04:00
parent b1acd55d84
commit f58e6ad92b
1 changed files with 15 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

22
util/kojira
View file

@ -803,18 +803,26 @@ class RepoManager(object):
def updateTagScores(self):
# call listTasks waitrepo
awaited = self.session.listTasks(opts={'method': ['waitrepo'],
'state': [koji.TASK_STATES['FREE'],
koji.TASK_STATES['ASSIGNED'],
koji.TASK_STATES['OPEN']]})
tasks = self.session.listTasks(opts={'method': ['waitrepo'],
'decode': True,
'state': [koji.TASK_STATES['FREE'],
koji.TASK_STATES['ASSIGNED'],
koji.TASK_STATES['OPEN']]})
awaited = set()
for task in awaited:
if tasks:
logger.debug("Checking %s active waitrepo tasks", len(tasks))
for task in tasks:
try:
awaited.add(koji.parse_task_params('waitrepo', task['request'])['tag'])
tag_param = koji.parse_task_params('waitrepo', task['request'])['tag']
taginfo = getTag(self.session, tag_param)
except Exception:
# ignore malformed tasks
self.logger.debug(f"Malformed task: {task}")
pass
continue
if taginfo:
awaited.add(taginfo['id'])
else:
self.logger.debug("Found waitrepo task %i with bad tag arg: %r", task['id'], tag_param)
for tag_id, entry in self.needed_tags.items():
if tag_id in awaited: