You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by we...@apache.org on 2022/07/19 04:25:56 UTC
[dolphinscheduler] 29/29: Return status
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 <we...@apache.org>
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