natas_hw
/
dolphinscheduler0701
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[Improvement-11468] Support re running historical version workflow (#11489) 

* Support re running historical version workflow

 Support re running historical version workflow

* Update ExecutorServiceImpl.java

* Update ExecutorServiceImpl.java
This commit is contained in:
insist777 2022-08-18 09:46:54 +08:00 committed by GitHub
parent 006d8e21a6
commit ebdf903dcc
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ExecutorServiceImpl.java
View File

@ -324,7 +324,9 @@ public class ExecutorServiceImpl extends BaseServiceImpl implements ExecutorServ
} }
/** /**
* do action to process instance：pause, stop, repeat, recover from pause, recover from stop * do action to process instance：pause, stop, repeat, recover from pause, recover from stop，rerun failed task
* *
* @param loginUser login user * @param loginUser login user
* @param projectCode project code * @param projectCode project code
@ -358,6 +360,7 @@ public class ExecutorServiceImpl extends BaseServiceImpl implements ExecutorServ
ProcessDefinition processDefinition = ProcessDefinition processDefinition =
processService.findProcessDefinition(processInstance.getProcessDefinitionCode(), processService.findProcessDefinition(processInstance.getProcessDefinitionCode(),
processInstance.getProcessDefinitionVersion()); processInstance.getProcessDefinitionVersion());
processDefinition.setReleaseState(ReleaseState.ONLINE);
if (executeType != ExecuteType.STOP && executeType != ExecuteType.PAUSE) { if (executeType != ExecuteType.STOP && executeType != ExecuteType.PAUSE) {
result = result =
checkProcessDefinitionValid(projectCode, processDefinition, checkProcessDefinitionValid(projectCode, processDefinition,