[PATCH 5/7] lnst.Controller.Machine: generate and store JobResult objects

From: Ondrej Lichtner <olichtne(a)redhat.com&gt; Generates a JobStartResult object when the "run_job" rpc call returns and stores it in the current RecipeRun. Generates a JobFinishResult object when a job_finished message is received and stores it in the current RecipeRun. Signed-off-by: Ondrej Lichtner <olichtne(a)redhat.com&gt; --- lnst/Controller/Machine.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/lnst/Controller/Machine.py b/lnst/Controller/Machine.py index b429721..09e7540 100644 --- a/lnst/Controller/Machine.py +++ b/lnst/Controller/Machine.py @@ -21,6 +21,7 @@ from lnst.Common.TestModule import BaseTestModule from lnst.Common.Version import lnst_version from lnst.Controller.Common import ControllerError from lnst.Controller.CtlSecSocket import CtlSecSocket +from lnst.Controller.RecipeResults import JobStartResult, JobFinishResult from lnst.Devices import device_classes from lnst.Devices.Device import Device from lnst.Devices.RemoteDevice import RemoteDevice @@ -365,7 +366,10 @@ class Machine(object): if job._desc is not None: logging.info("Job description: %s" % job._desc) - return self.rpc_call("run_job", job._to_dict(), netns=job.netns) + res = self.rpc_call("run_job", job._to_dict(), netns=job.netns) + + self._recipe.current_run.add_result(JobStartResult(job, res)) + return res def wait_for_job(self, job, timeout): res = True @@ -426,6 +430,7 @@ class Machine(object): job_id = msg["job_id"] job = self._jobs[job_id] job._res = msg["result"] + self._recipe.current_run.add_result(JobFinishResult(job)) def kill(self, job, signal): if job.id not in self._jobs: -- 2.16.1