From 941771e7b1fcc08aec83a11e6fb027c254652d2b Mon Sep 17 00:00:00 2001 From: Mike McLean Date: Wed, 13 Nov 2024 12:27:55 -0500 Subject: [PATCH] partial: split autoregen --- util/kojira | 22 ++++++++++++++++------ 1 file changed, 16 insertions(+), 6 deletions(-) diff --git a/util/kojira b/util/kojira index 27c9e82f..f278c610 100755 --- a/util/kojira +++ b/util/kojira @@ -481,7 +481,7 @@ class RepoManager(object): self.logger.info('regenLoop starting') try: while True: - self.regenRepos() + self.session.repo.checkQueue() time.sleep(self.options.sleeptime) except Exception: self.logger.exception('Error in regen thread') @@ -489,6 +489,21 @@ class RepoManager(object): finally: session.logout() + def autoregenLoop(self, session): + """Triggers automatic regens as needed/possible. Runs in a separate thread""" + self.session = session + self.logger = logging.getLogger("koji.repo.autoregen") + self.logger.info('autoregenLoop starting') + try: + while True: + self.session.repo.autoRequests() + time.sleep(self.options.sleeptime) + except Exception: + self.logger.exception('Error in auto regen thread') + raise + finally: + session.logout() + def rmtreeLoop(self, session): self.session = session logger = logging.getLogger("koji.repo.rmtree") @@ -649,11 +664,6 @@ class RepoManager(object): elif repo.state == koji.REPO_PROBLEM: repo.handle_problem() - def regenRepos(self): - """Trigger repo requests as needed""" - self.session.repo.autoRequests() - self.session.repo.checkQueue() - def start_currency_checker(session, repomgr): subsession = session.subsession()