fix issue with failing child tasks in run_tasks_concurrent

Author: pk910

pkg/coordinator/tasks/run_task_matrix/README.md

@@ -14,6 +14,9 @@ The `run_task_matrix` task is designed to execute a specified task multiple time
 - **`failTaskCount`**:\
   The number of child tasks that may to fail (result status "failure") before the `run_task_matrix` task to stops and returns a failure result. A value of 0 means that the appearance of any failure in child tasks will cause the overall task to fail.
 
+- **`failOnUndecided`**:\
+  If set to true, the `run_task_matrix` task will fail if neither the `succeedTaskCount` nor the `failTaskCount` is reached.
+
 - **`matrixValues`**:\
   An array of values that form the matrix. Each value in this array is used to run the child task with a different input.
 
@@ -33,7 +36,9 @@ Default settings for the `run_task_matrix` task:
     runConcurrent: false
     succeedTaskCount: 0
     failTaskCount: 0
+    failOnUndecided: true
     matrixValues: []
     matrixVar: ""
     task: {}
 ```
+

pkg/coordinator/tasks/run_task_matrix/config.go

@@ -16,6 +16,9 @@ type Config struct {
 	// number of failed child tasks to make this task fail (0 = all tasks)
 	FailTaskCount uint64 `yaml:"failTaskCount" json:"failTaskCount"`
 
+	// fail task if neither succeedTaskCount nor failTaskCount is reached, but all tasks completed
+	FailOnUndecided bool `yaml:"failOnUndecided" json:"failOnUndecided"`
+
 	// matrix variable name
 	MatrixValues []interface{} `yaml:"matrixValues" json:"matrixValues"`
 
@@ -27,7 +30,9 @@ type Config struct {
 }
 
 func DefaultConfig() Config {
-	return Config{}
+	return Config{
+		FailOnUndecided: true,
+	}
 }
 
 func (c *Config) Validate() error {

pkg/coordinator/tasks/run_task_matrix/task.go

@@ -229,7 +229,12 @@ func (t *Task) Execute(ctx context.Context) error {
 			if !taskComplete {
 				taskComplete = true
 
-				t.ctx.SetResult(types.TaskResultSuccess)
+				if t.config.FailOnUndecided {
+					t.ctx.SetResult(types.TaskResultFailure)
+				} else {
+					t.ctx.SetResult(types.TaskResultSuccess)
+				}
+
 				t.logger.Infof("all child tasks completed (%v success, %v failure)", successCount, failureCount)
 			}
 		}

pkg/coordinator/tasks/run_tasks_concurrent/README.md

@@ -11,6 +11,9 @@ The `run_tasks_concurrent` task allows for the parallel execution of multiple ta
 - **`failTaskCount`**:\
   The minimum number of child tasks that need to complete with a "failure" result for the `run_tasks_concurrent` task to stop and return a failure result. A value of 1 means the overall task will fail as soon as one child task fails.
 
+- **`failOnUndecided`**:\
+  If set to true, the `run_tasks_concurrent` task will fail if neither the `succeedTaskCount` nor the `failTaskCount` is reached.
+
 - **`newVariableScope`**:\
   If set to true, a new variable scope will be created for the child tasks, if not, the child tasks will use the same variable scope as the parent task.
 
@@ -26,6 +29,7 @@ Default settings for the `run_tasks_concurrent` task:
   config:
     succeedTaskCount: 0
     failTaskCount: 1
+    failOnUndecided: false
     newVariableScope: true
     tasks: []
 ```