Send the work data result as soon as we know it

Change-Id: I40b46e19d298f18b3ca3cf031612ae94b3874bfa
This commit is contained in:
Joshua Hesketh 2014-01-31 13:10:29 +11:00
parent 9900554992
commit 3cda79ff66

View File

@ -92,17 +92,19 @@ class Task(object):
""" Send the WORK DATA in json format for job """
self.log.debug("Send the work data response: %s" %
json.dumps(self._get_work_data()))
if self.success:
self.work_data['result'] = 'SUCCESS'
else:
self.work_data['result'] = '\n'.join(self.messages)
self.job.sendWorkData(json.dumps(self._get_work_data()))
def _send_final_results(self):
self._send_work_data()
if self.success:
self.work_data['result'] = 'SUCCESS'
self.job.sendWorkComplete(
json.dumps(self._get_work_data()))
else:
self.work_data['result'] = '\n'.join(self.messages)
self.job.sendWorkFail()
def _do_next_step(self):