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 8340f3f803 [Fix-16813] Missing implememts in
isTaskExecutionRunnableForbidden (#16814)
8340f3f803 is described below
commit 8340f3f803dbd7bb13b2d35c64baa734dcdfae56
Author: lile <[email protected]>
AuthorDate: Mon Nov 18 19:20:11 2024 +0800
[Fix-16813] Missing implememts in isTaskExecutionRunnableForbidden (#16814)
---
.../server/master/engine/graph/WorkflowExecutionGraph.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/graph/WorkflowExecutionGraph.java
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/graph/WorkflowExecutionGraph.java
index 0c2bf92d10..20a65d45a2 100644
---
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/graph/WorkflowExecutionGraph.java
+++
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/graph/WorkflowExecutionGraph.java
@@ -17,6 +17,7 @@
package org.apache.dolphinscheduler.server.master.engine.graph;
+import org.apache.dolphinscheduler.common.enums.Flag;
import org.apache.dolphinscheduler.dao.entity.TaskInstance;
import org.apache.dolphinscheduler.plugin.task.api.enums.TaskExecutionStatus;
import org.apache.dolphinscheduler.plugin.task.api.utils.TaskTypeUtils;
@@ -252,7 +253,7 @@ public class WorkflowExecutionGraph implements
IWorkflowExecutionGraph {
@Override
public boolean isTaskExecutionRunnableForbidden(final
ITaskExecutionRunnable taskExecutionRunnable) {
- return false;
+ return (taskExecutionRunnable.getTaskDefinition().getFlag() ==
Flag.NO);
}
/**
