From 97be4ffcb291019cbae5fd715bbb325d72f5c6f1 Mon Sep 17 00:00:00 2001 From: wb-msm261421 Date: Fri, 29 Dec 2023 11:27:04 +0800 Subject: [PATCH] fix(backend): diagnose sbs create offline task status change --- sysom_server/sysom_diagnosis/apps/task/executor.py | 2 ++ sysom_server/sysom_diagnosis/apps/task/helper.py | 4 ++-- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/sysom_server/sysom_diagnosis/apps/task/executor.py b/sysom_server/sysom_diagnosis/apps/task/executor.py index 5072ba43..62353a65 100644 --- a/sysom_server/sysom_diagnosis/apps/task/executor.py +++ b/sysom_server/sysom_diagnosis/apps/task/executor.py @@ -68,6 +68,8 @@ class DiagnosisTaskExecutor(AsyncEventExecutor): is_offline = await DiagnosisHelper.preprocess_post_wrapper_async(instance, res) if is_offline: return + + await DiagnosisHelper._update_job_async(instance, status="Running") # 2. Execute and Postprocess if not res.offline_mode: diff --git a/sysom_server/sysom_diagnosis/apps/task/helper.py b/sysom_server/sysom_diagnosis/apps/task/helper.py index 3c0e17be..47549620 100644 --- a/sysom_server/sysom_diagnosis/apps/task/helper.py +++ b/sysom_server/sysom_diagnosis/apps/task/helper.py @@ -325,7 +325,7 @@ class DiagnosisHelper: # If the pre-processor executes successfully, the parameters are compliant # and the Job instance is updated await DiagnosisHelper._update_job_async( - instance, command=diagnosis_task.to_dict(), status="Running" + instance, command=diagnosis_task.to_dict() ) except Exception as exc: logger.exception(f"Diagnosis preprocess error: {str(exc)}") @@ -375,7 +375,7 @@ class DiagnosisHelper: wrapper = _get_pre_processor_post_wrapper(preprocess_post_wrapper)() wrapper.process(instance.task_id, diagnosis_task) await DiagnosisHelper._update_job_async( - instance, command=diagnosis_task.to_dict() + instance, command=diagnosis_task.to_dict(), status="Running" ) except Exception as exc: logger.exception(f"Diagnosis preprocess post wrapper error: {str(exc)}") -- Gitee