diff --git a/sysom_server/sysom_diagnosis/apps/task/executor.py b/sysom_server/sysom_diagnosis/apps/task/executor.py
index 5072ba437eedbd82dd06a0153f49570da48a1dc0..3622a65230033eb72445245f9c1700c3e8eba8ea 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 3c0e17bed84d1ac28e528184107131e545074589..475496200a94d6b02fb733cfa2d1efc614f00ef6 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)}")