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 a5c20a02d0 [Fix-17353] Dependent calculation ignore 
need-fault-tolerance state (#17385)
a5c20a02d0 is described below

commit a5c20a02d08023573655301e394d8fa13afda3c9
Author: lile <[email protected]>
AuthorDate: Wed Jul 30 23:10:12 2025 +0800

    [Fix-17353] Dependent calculation ignore need-fault-tolerance state (#17385)
---
 .../org/apache/dolphinscheduler/dao/mapper/TaskInstanceMapper.xml       | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TaskInstanceMapper.xml
 
b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TaskInstanceMapper.xml
index 49b8f45d5c..e33b472fec 100644
--- 
a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TaskInstanceMapper.xml
+++ 
b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/TaskInstanceMapper.xml
@@ -245,6 +245,7 @@
         from t_ds_task_instance
         where 1=1
         and workflow_instance_id = #{workflowInstanceId}
+        and state != 8
         <if test="taskCodes != null and taskCodes.size() != 0">
             and task_code in
             <foreach collection="taskCodes" index="index" item="i" open="(" 
separator="," close=")">
@@ -263,6 +264,7 @@
         from t_ds_task_instance
         where workflow_instance_id = #{workflowInstanceId}
         and task_code = #{taskCode}
+        and state != 8
         order by end_time desc limit 1
     </select>
 

Reply via email to