diff --git a/sysom_server/sysom_diagnosis/apps/task/executor.py b/sysom_server/sysom_diagnosis/apps/task/executor.py index 5072ba437eedbd82dd06a0153f49570da48a1dc0..53da9de4388a8ba54931c27ee6bfa52cf2255ec9 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 3c0e17bed84d1ac28e528184107131e545074589..97977b0677d3011608ba235f9025a11d1964d49e 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)}")