(dolphinscheduler) branch dev updated: [FIX] Fix cannot recover a stopped workflow instance (#15880)

[wenjun]

This is an automated email from the ASF dual-hosted git repository.

wenjun pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new e66441a2c9 [FIX] Fix cannot recover a stopped workflow instance 
(#15880)
e66441a2c9 is described below

commit e66441a2c9ec38387b34f3712055af7308876efc
Author: privking <43061765+privk...@users.noreply.github.com>
AuthorDate: Sat Apr 20 07:32:18 2024 +0800

    [FIX] Fix cannot recover a stopped workflow instance (#15880)
---
 .../workflow/instance/pause/recover/RecoverExecuteFunction.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/executor/workflow/instance/pause/recover/RecoverExecuteFunction.java
 
b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/executor/workflow/instance/pause/recover/RecoverExecuteFunction.java
index 149e1abd29..34bd2561b1 100644
--- 
a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/executor/workflow/instance/pause/recover/RecoverExecuteFunction.java
+++ 
b/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()));