Merge "Fixed status update for job execution"
This commit is contained in:
commit
525c6441b6
@ -125,7 +125,7 @@ def run_job(job_execution_id):
|
||||
|
||||
conductor.job_execution_update(
|
||||
context.ctx(), job_execution_id,
|
||||
{'status': 'FAILED',
|
||||
{'info': {'status': 'FAILED'},
|
||||
'start_time': datetime.datetime.now(),
|
||||
'end_time': datetime.datetime.now()})
|
||||
|
||||
|
@ -389,7 +389,7 @@ class TestJobManager(base.SaharaWithDbTestCase):
|
||||
|
||||
self.assertEqual(1, job_ex_upd.call_count)
|
||||
|
||||
new_status = job_ex_upd.call_args[0][2]["status"]
|
||||
new_status = job_ex_upd.call_args[0][2]["info"]["status"]
|
||||
self.assertEqual('FAILED', new_status)
|
||||
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user