updating example of a matrix feature

Adding two new validation:

* onError with matrix: when a task fan out for a given number of instances,
pipeline controller must apply the onError to each running instance.

* retry with matrix: when a task has specified retry, that specification
must apply to all the instances of fanned out task.

Being consistent with the rest of the reasons, dropping "Reason" from
"ReasonInvalidMatrixParameterTypes".

Updated the error reported in "ValidateParameterTypesInMatrix" to include
name of the pipelineTask.

Signed-off-by: Priti Desai <pdesai@us.ibm.com>

examples/v1/pipelineruns/alpha/pipelinerun-with-matrix.yaml

@@ -64,6 +64,46 @@ spec:
             - name: echo
               image: ubuntu
               script: exit 1
+      - name: matrix-with-task-using-onerror
+        matrix:
+          params:
+            - name: version
+              value:
+                - "1"
+                - "2"
+        taskSpec:
+          params:
+            - name: version
+          steps:
+            - name: echo
+              image: ubuntu
+              onError: continue
+              script: exit 1
+      - name: matrix-with-task-retries
+        retries: 1
+        params:
+          - name: pipelineTask-retries
+            value: $(context.pipelineTask.retries)
+        matrix:
+          params:
+            - name: version
+              value:
+                - "1"
+                - "2"
+        taskSpec:
+          params:
+            - name: version
+            - name: pipelineTask-retries
+          steps:
+            - image: alpine
+              script: |
+                #!/usr/bin/env sh
+                if [ "$(context.task.retry-count)" == "$(params.pipelineTask-retries)" ]; then
+                  echo "This is the last retry."
+                  exit 0;
+                fi
+                echo "The PipelineTask has retried $(context.task.retry-count) times."
+                exit 1
     finally:
       - name: matrix-params-with-empty-array-skipped-in-finally
         matrix:

pkg/reconciler/pipelinerun/pipelinerun.go

@@ -121,7 +121,7 @@ const (
 	// all of the running TaskRuns as timed out failed.
 	ReasonCouldntTimeOut = "PipelineRunCouldntTimeOut"
 	// ReasonInvalidMatrixParameterTypes indicates a matrix contains invalid parameter types
-	ReasonInvalidMatrixParameterTypes = "ReasonInvalidMatrixParameterTypes"
+	ReasonInvalidMatrixParameterTypes = "InvalidMatrixParameterTypes"
 	// ReasonInvalidTaskResultReference indicates a task result was declared
 	// but was not initialized by that task
 	ReasonInvalidTaskResultReference = "InvalidTaskResultReference"

pkg/reconciler/pipelinerun/resources/validate_params.go

@@ -96,15 +96,17 @@ func ValidateParameterTypesInMatrix(state PipelineRunState) error {
 			for _, include := range m.Include {
 				for _, param := range include.Params {
 					if param.Value.Type != v1.ParamTypeString {
-						return fmt.Errorf("parameters of type string only are allowed, but param %s has type %s", param.Name, string(param.Value.Type))
+						return fmt.Errorf("parameters of type string only are allowed, but param \"%s\" has type \"%s\" in pipelineTask \"%s\"",
+							param.Name, string(param.Value.Type), rpt.PipelineTask.Name)
 					}
 				}
 			}
 		}
 		if m.HasParams() {
 			for _, param := range m.Params {
 				if param.Value.Type != v1.ParamTypeArray {
-					return fmt.Errorf("parameters of type array only are allowed, but param %s has type %s", param.Name, string(param.Value.Type))
+					return fmt.Errorf("parameters of type array only are allowed, but param \"%s\" has type \"%s\" in pipelineTask \"%s\"",
+						param.Name, string(param.Value.Type), rpt.PipelineTask.Name)
 				}
 			}
 		}

pkg/reconciler/pipelinerun/resources/validate_params_test.go

@@ -355,7 +355,7 @@ func TestValidatePipelineParameterTypes(t *testing.T) {
 					}}},
 			},
 		}},
-		wantErrs: "parameters of type array only are allowed, but param foo has type string",
+		wantErrs: "parameters of type array only are allowed, but param \"foo\" has type \"string\" in pipelineTask \"task\"",
 	}, {
 		desc: "parameters in include matrix are strings",
 		state: resources.PipelineRunState{{
@@ -386,7 +386,7 @@ func TestValidatePipelineParameterTypes(t *testing.T) {
 					}}},
 			},
 		}},
-		wantErrs: "parameters of type string only are allowed, but param foobar has type array",
+		wantErrs: "parameters of type string only are allowed, but param \"foobar\" has type \"array\" in pipelineTask \"task\"",
 	}, {
 		desc: "parameters in include matrix are objects",
 		state: resources.PipelineRunState{{
@@ -409,7 +409,7 @@ func TestValidatePipelineParameterTypes(t *testing.T) {
 					}}},
 			},
 		}},
-		wantErrs: "parameters of type string only are allowed, but param barfoo has type object",
+		wantErrs: "parameters of type string only are allowed, but param \"barfoo\" has type \"object\" in pipelineTask \"task\"",
 	}} {
 		t.Run(tc.desc, func(t *testing.T) {
 			err := resources.ValidateParameterTypesInMatrix(tc.state)