openstack/deb-sahara
Code Issues Proposed changes

Fixed error on attempt to delete job execution several times

Browse Source 
Change-Id: Ic46a837523a4b4cb3511b33103a39279edfd3f4b
Closes-Bug: #1395920
This commit is contained in:
Andrew Lazarev 2014-11-24 16:13:07 -08:00
parent 7505c71848
commit 93b461f59e
2 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
sahara/service/edp/job_manager.py
View File

@ -165,6 +165,11 @@ def cancel_job(job_execution_id):
context.sleep(3)
job_execution = conductor.job_execution_get(
ctx, job_execution_id)
if not job_execution:
LOG.info(_LI("Job execution %(job_exec_id)s was deleted. "
"Canceling current operation."),
{'job_exec_id': job_execution_id})
return job_execution
else:
LOG.info(_LI("Job execution status %(job)s: %(status)s"),
{'job': job_execution.id,

5
sahara/service/ops.py
View File

@ -299,7 +299,10 @@ def _cancel_job_execution(job_execution_id):
def _delete_job_execution(job_execution_id):
try:
_cancel_job_execution(job_execution_id)
job_execution = job_manager.cancel_job(job_execution_id)
if not job_execution:
# job_execution was deleted already, nothing to do
return
except exceptions.CancelingFailed:
LOG.error(_LE("Job execution %s can't be cancelled in time. "
"Deleting it anyway."), job_execution_id)