From 73dc84af722ea84c93e6048737ecd03b444cac5e Mon Sep 17 00:00:00 2001 From: wb-msm261421 Date: Fri, 29 Dec 2023 11:47:11 +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 | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/sysom_server/sysom_diagnosis/apps/task/executor.py b/sysom_server/sysom_diagnosis/apps/task/executor.py index 5072ba43..53da9de4 100644 --- a/sysom_server/sysom_diagnosis/apps/task/executor.py +++ b/sysom_server/sysom_diagnosis/apps/task/executor.py @@ -67,6 +67,7 @@ class DiagnosisTaskExecutor(AsyncEventExecutor): # 1.1 Preprocess post wrapper is_offline = await DiagnosisHelper.preprocess_post_wrapper_async(instance, res) if is_offline: + await DiagnosisHelper._update_job_async(instance, status="Running") return # 2. Execute and Postprocess diff --git a/sysom_server/sysom_diagnosis/apps/task/helper.py b/sysom_server/sysom_diagnosis/apps/task/helper.py index 3c0e17be..97977b06 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)}") -- Gitee