Browse Source

fix bug: failover process instance would change the state

pull/2/head
lenboo 5 years ago
parent
commit
d7110c6615
  1. 5
      escheduler-dao/src/main/java/cn/escheduler/dao/ProcessDao.java

5
escheduler-dao/src/main/java/cn/escheduler/dao/ProcessDao.java

@ -581,6 +581,8 @@ public class ProcessDao extends AbstractBaseDao {
processInstance.setScheduleTime(command.getScheduleTime()); processInstance.setScheduleTime(command.getScheduleTime());
} }
processInstance.setHost(host); processInstance.setHost(host);
ExecutionStatus runStatus = ExecutionStatus.RUNNING_EXEUTION;
int runTime = processInstance.getRunTimes(); int runTime = processInstance.getRunTimes();
switch (commandType){ switch (commandType){
case START_PROCESS: case START_PROCESS:
@ -621,6 +623,7 @@ public class ProcessDao extends AbstractBaseDao {
case RECOVER_TOLERANCE_FAULT_PROCESS: case RECOVER_TOLERANCE_FAULT_PROCESS:
// recover tolerance fault process // recover tolerance fault process
processInstance.setRecovery(Flag.YES); processInstance.setRecovery(Flag.YES);
runStatus = processInstance.getState();
break; break;
case COMPLEMENT_DATA: case COMPLEMENT_DATA:
// delete all the valid tasks when complement data // delete all the valid tasks when complement data
@ -652,7 +655,7 @@ public class ProcessDao extends AbstractBaseDao {
default: default:
break; break;
} }
processInstance.setState(ExecutionStatus.RUNNING_EXEUTION); processInstance.setState(runStatus);
return processInstance; return processInstance;
} }

Loading…
Cancel
Save