From 4ac8654d4d853161a6359f11d49eb4c7e2184423 Mon Sep 17 00:00:00 2001 From: wb-msm261421 Date: Thu, 28 Dec 2023 16:27:45 +0800 Subject: [PATCH] fix(backend): diagnose sbs create offline task status change --- sysom_server/sysom_diagnosis/apps/task/executor.py | 1 + sysom_server/sysom_diagnosis/apps/task/helper.py | 4 ++-- 2 files changed, 3 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..3622a652 100644 --- a/sysom_server/sysom_diagnosis/apps/task/executor.py +++ b/sysom_server/sysom_diagnosis/apps/task/executor.py @@ -63,6 +63,7 @@ class DiagnosisTaskExecutor(AsyncEventExecutor): if not res: raise Exception("Diagnosis preprocess error, DiagnosisTask is None") + await DiagnosisHelper._update_job_async(instance, status="Running") # 1.1 Preprocess post wrapper is_offline = await DiagnosisHelper.preprocess_post_wrapper_async(instance, res) 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