This is an automated email from the ASF dual-hosted git repository. wenjun pushed a commit to branch 3.0.0-prepare in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
commit 6df8593add92ae8f6cbfcc380a693f0dbaf4e93b Author: Wenjun Ruan <[email protected]> AuthorDate: Tue Jul 19 12:24:59 2022 +0800 Return status --- .../dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java index 0e94b0318d..10c54a5b3a 100644 --- a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java +++ b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java @@ -1524,6 +1524,7 @@ public class WorkflowExecuteRunnable implements Callable<WorkflowSubmitStatue> { if (state == ExecutionStatus.READY_BLOCK) { ExecutionStatus executionStatus = processReadyBlock(); logger.info("The workflowInstance is ready to block, the workflowInstance status is {}", executionStatus); + return executionStatus } // waiting thread @@ -1552,6 +1553,7 @@ public class WorkflowExecuteRunnable implements Callable<WorkflowSubmitStatue> { executionStatus = ExecutionStatus.SUCCESS; } logger.info("The workflowInstance is ready to stop, the workflow status is {}", executionStatus); + return executionStatus; } // process failure
