repo monitor: Only keep looking for scheduling repos
Once the repo is building again, we don't want to poll but wait for amqp again
This commit is contained in:
parent
3c2ced48e9
commit
6ce3c9b28f
@ -65,7 +65,6 @@ class Listener(PubSubConsumer):
|
|||||||
return None
|
return None
|
||||||
ids[arch] = repoid
|
ids[arch] = repoid
|
||||||
self.logger.info('All of {}/{} finished'.format(project, repository))
|
self.logger.info('All of {}/{} finished'.format(project, repository))
|
||||||
self.repositories_to_monitor.discard(f'{project}/{repository}')
|
|
||||||
return ids
|
return ids
|
||||||
|
|
||||||
def is_part_of_namespaces(self, project):
|
def is_part_of_namespaces(self, project):
|
||||||
@ -99,6 +98,7 @@ class Listener(PubSubConsumer):
|
|||||||
repos = list(self.repositories_to_monitor)
|
repos = list(self.repositories_to_monitor)
|
||||||
random.shuffle(repos)
|
random.shuffle(repos)
|
||||||
for entry in repos:
|
for entry in repos:
|
||||||
|
self.repositories_to_monitor.discard(entry)
|
||||||
project, repository = entry.split('/')
|
project, repository = entry.split('/')
|
||||||
self.logger.debug(f"Recheck repo {project}/{repository}")
|
self.logger.debug(f"Recheck repo {project}/{repository}")
|
||||||
self.update_repo(project, repository)
|
self.update_repo(project, repository)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user