fix update job info bug

Signed-off-by: wzh <[email protected]>
pyisong · Jun 10, 2020 · 5aebd5c · 5aebd5c
1 parent 770af53
commit 5aebd5c
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/fate_flow/manager/tracking_manager.py b/fate_flow/manager/tracking_manager.py
@@ -348,12 +348,13 @@ def save_job_info(self, role, party_id, job_info, create=False):
                 if (job_info['f_status'] in [JobStatus.FAILED, JobStatus.TIMEOUT]) and (not job.f_end_time):
                     if not job.f_start_time:
                         return
-                    job.f_end_time = current_timestamp()
-                    job.f_elapsed = job.f_end_time - job.f_start_time
-                    job.f_update_time = current_timestamp()
+                    job_info['f_end_time'] = current_timestamp()
+                    job_info['f_elapsed'] = job.f_end_time - job.f_start_time
+                    job_info['f_update_time'] = current_timestamp()
+
                 if (job_info['f_status'] in [JobStatus.FAILED, JobStatus.TIMEOUT,
                                              JobStatus.CANCELED, JobStatus.COMPLETE]):
-                    job.f_tag = 'job_end'
+                    job_info['f_tag'] = 'job_end'
             update_fields = []
             for k, v in job_info.items():
                 try: