summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorBen Hutchings <ben.hutchings@codethink.co.uk>2020-09-15 01:00:48 +0100
committerBen Hutchings <ben.hutchings@codethink.co.uk>2020-09-15 01:59:40 +0100
commit031cb3b6cbf52cd0becd9fdad0facc6c34c083af (patch)
treeaad9e02464472a44ecd2119fdfbac65005042a79
parentdb9192dbb033df2f306b87e0e765f3142896d013 (diff)
downloadlorry-controller-031cb3b6cbf52cd0becd9fdad0facc6c34c083af.tar.gz
lorry-controller-remove-old-jobs: Use a single loop in process_args
In order to filter jobs earlier, we need to have a single loop over jobs in process_args(). Related to #18.
-rwxr-xr-xlorry-controller-remove-old-jobs15
1 files changed, 5 insertions, 10 deletions
diff --git a/lorry-controller-remove-old-jobs b/lorry-controller-remove-old-jobs
index d31b540..677e0cd 100755
--- a/lorry-controller-remove-old-jobs
+++ b/lorry-controller-remove-old-jobs
@@ -69,22 +69,17 @@ class OldJobRemover(cliapp.Application):
def process_args(self, args):
logging.info('Removing old jobs from Lorry Controller STATEDB')
- job_ids = self.list_jobs()
-
- job_infos = []
- for job_id in job_ids:
+ for job_id in self.list_jobs():
try:
- job_infos.append(self.get_job_info(job_id))
+ job_info = self.get_job_info(job_id)
except urllib.error.HTTPError as e:
logging.warning(
'Trouble getting job info for job %s: %s' %
(job_id, str(e)))
+ continue
- ids_of_jobs_to_remove = \
- [job_info for job_info in job_infos if self.is_old(job_info)]
-
- for job_info in ids_of_jobs_to_remove:
- self.remove_job(job_info.job_id)
+ if self.is_old(job_info):
+ self.remove_job(job_info.job_id)
def list_jobs(self):
data = self.get('/1.0/list-jobs')