openstack
/
freezer
Code Issues Proposed changes

Remove unneeded if statements 

Change-Id: I333dea283bedd2391b46978d99d251cfa77ce5c1
This commit is contained in:
Chen 2018-10-24 17:47:52 +08:00
parent b1c6d533d7
commit 3c9528d0fa
1 changed files with 8 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
freezer/scheduler/freezer_scheduler.py
View File

@ -151,9 +151,8 @@ class FreezerScheduler(object):
def create_job(self, job_doc):
job = scheduler_job.Job.create(self, self.freezerc_executable, job_doc)
if job:
self.jobs[job.id] = job
LOG.info("Created job {0}".format(job.id))
self.jobs[job.id] = job
LOG.info("Created job {0}".format(job.id))
return job
def poll(self):
@ -170,13 +169,13 @@ class FreezerScheduler(object):
job_id = job_doc['job_id']
work_job_id_list.append(job_id)
job = self.jobs.get(job_id, None) or self.create_job(job_doc)
if job:
# check for abort status
if job_doc['job_schedule']['event'] == 'abort':
pid = int(job_doc['job_schedule']['current_pid'])
utils.terminate_subprocess(pid, 'freezer-agent')
job.process_event(job_doc)
# check for abort status
if job_doc['job_schedule']['event'] == 'abort':
pid = int(job_doc['job_schedule']['current_pid'])
utils.terminate_subprocess(pid, 'freezer-agent')
job.process_event(job_doc)
# request removal of any job that has been removed in the api
for job_id, job in self.jobs.items():