Browse Source

[FIX] Fix cannot recover a stopped workflow instance (#15880)

3.2.2-release-bak
privking 7 months ago committed by GitHub
parent
commit
e66441a2c9
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
  1. 2
      dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/executor/workflow/instance/pause/recover/RecoverExecuteFunction.java

2
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/executor/workflow/instance/pause/recover/RecoverExecuteFunction.java

@ -43,7 +43,7 @@ public class RecoverExecuteFunction implements ExecuteFunction<RecoverExecuteReq
@Override
public RecoverExecuteResult execute(RecoverExecuteRequest request) throws ExecuteRuntimeException {
ProcessInstance workflowInstance = request.getWorkflowInstance();
if (!workflowInstance.getState().isPause()) {
if (!(workflowInstance.getState().isPause() || workflowInstance.getState().isStop())) {
throw new ExecuteRuntimeException(
String.format("The workflow instance: %s state is %s, cannot recovery", workflowInstance.getName(),
workflowInstance.getState()));

Loading…
Cancel
Save