@@ -76,21 +76,10 @@ public void onEvent(JobTerminateEvent event) {
7676 // correct status
7777 TaskStatus taskStatus = TerminateProcessor .correctTaskStatus (terminateProcessors , jobEntity .getJobType (),
7878 scheduleTask , event .getStatus ().convertTaskStatus (), event .getTaskResult ());
79- if (scheduleTask .getStatus () != taskStatus ) {
80- // CAS
81- int affectRows = scheduleTaskService .updateStatusById (scheduleTask .getId (), taskStatus ,
82- Collections .singletonList (scheduleTask .getStatus ().name ()));
83- if (affectRows > 0 ) {
84- log .info ("Update schedule task status from {} to {} succeed,scheduleTaskId={}" ,
85- scheduleTask .getStatus (),
86- taskStatus , scheduleTask .getId ());
87- scheduleTask .setStatus (taskStatus );
88- } else {
89- log .info ("Update schedule task status from {} to {} failed,scheduleTaskId={}" ,
90- scheduleTask .getStatus (),
91- taskStatus , scheduleTask .getId ());
92- }
93- }
79+ // correct to final status
80+ scheduleTaskService .updateStatusById (scheduleTask .getId (), taskStatus );
81+ log .info ("Update schedule task status to {} succeed,scheduleTaskId={}" , taskStatus , scheduleTask .getId ());
82+ scheduleTask .setStatus (taskStatus );
9483 // Refresh the schedule status after the task is completed.
9584 scheduleService .refreshScheduleStatus (Long .parseLong (scheduleTask .getJobName ()));
9685 // Trigger the alarm if the task is failed or canceled.
0 commit comments