From 2e18fddb6f15101a2d363b30e9c90423d7900cea Mon Sep 17 00:00:00 2001 From: Zack Cerza Date: Wed, 25 Jun 2014 10:38:38 -0600 Subject: [PATCH] Only delete jobs that match the pattern Signed-off-by: Zack Cerza --- teuthology/beanstalk.py | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/teuthology/beanstalk.py b/teuthology/beanstalk.py index a9967d8d0a18a..6776300b60c07 100644 --- a/teuthology/beanstalk.py +++ b/teuthology/beanstalk.py @@ -124,6 +124,15 @@ class RunPrinter(JobProcessor): class JobDeleter(JobProcessor): + def __init__(self, pattern): + self.pattern = pattern + super(JobDeleter, self).__init__() + + def add_job(self, job_id, job_config, job_obj=None): + job_name = job_config['name'] + if self.pattern in job_name: + super(JobDeleter, self).add_job(job_id, job_config, job_obj) + def process_job(self, job_id): job_config = self.jobs[job_id]['job_config'] job_name = job_config['name'] @@ -147,7 +156,7 @@ def main(args): watch_tube(connection, machine_type) if delete: walk_jobs(connection, machine_type, - JobDeleter()) + JobDeleter(delete)) elif runs: walk_jobs(connection, machine_type, RunPrinter()) -- 2.39.5