fix: subtasks always get skipped

apache · Apr 1, 2024 · f162af8 · f162af8
1 parent cbcaaae
commit f162af8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/backend/core/runner/run_task.go b/backend/core/runner/run_task.go
@@ -314,7 +314,7 @@ func RunPluginSubTasks(
 		if !subtaskMeta.ForceRunOnResume {
 			sfc := errors.Must1(
 				basicRes.GetDal().Count(
-					dal.From(&models.Subtask{}), dal.Where("task_id = ? AND name = ?", task.ID, subtaskMeta.Name),
+					dal.From(&models.Subtask{}), dal.Where("task_id = ? AND name = ? AND finished_at IS NOT NULL", task.ID, subtaskMeta.Name),
 				),
 			)
 			subtaskFinsied = sfc > 0