Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions pkg/apis/pipeline/v1beta1/pipeline_validation.go
Original file line number Diff line number Diff line change
Expand Up @@ -811,6 +811,10 @@ func findAndValidateResultRefsForMatrix(tasks []PipelineTask, taskMapping map[st
func validateMatrixedPipelineTaskConsumed(expressions []string, taskMapping map[string]PipelineTask) (resultRefs []*ResultRef, errs *apis.FieldError) {
var filteredExpressions []string
for _, expression := range expressions {
// if it is not matrix result ref expression, skip
if !resultref.LooksLikeResultRef(expression) {
continue
}
// ie. "tasks.<pipelineTaskName>.results.<resultName>[*]"
subExpressions := strings.Split(expression, ".")
pipelineTask := subExpressions[1] // pipelineTaskName
Expand Down
50 changes: 50 additions & 0 deletions pkg/apis/pipeline/v1beta1/pipeline_validation_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -167,6 +167,56 @@ func TestPipeline_Validate_Success(t *testing.T) {
}},
},
},
}, {
name: "param with different type of values with matrix and invalid result ref",
p: &Pipeline{
ObjectMeta: metav1.ObjectMeta{
Name: "pipelinelinename",
},
Spec: PipelineSpec{
Tasks: []PipelineTask{{
Name: "echo-result",
TaskSpec: &EmbeddedTask{TaskSpec: TaskSpec{
Results: []TaskResult{{
Name: "output",
Type: ResultsTypeString,
}},
Steps: []Step{{
Name: "emit-a-result",
Image: "mirror.gcr.io/bash",
Script: "#!/usr/bin/env bash\necho -n \"some data\" | tee $(results.output.path)",
}},
}},
}, {
Name: "consume-result",
Matrix: &Matrix{
Params: Params{{
Name: "version", Value: ParamValue{ArrayVal: []string{"1", "2"}},
}},
},
Params: Params{
{
Name: "bad-input",
Value: ParamValue{
Type: ParamTypeString,
StringVal: "$(tasks)-$(tasks.echo-result.results.output)",
},
},
},
TaskSpec: &EmbeddedTask{TaskSpec: TaskSpec{
Params: []ParamSpec{{
Name: "bad-input",
Type: ParamTypeString,
}},
Steps: []Step{{
Name: "consume-the-result",
Image: "mirror.gcr.io/bash",
Script: "#!/usr/bin/env bash\necho -n \"input: $(params.bad-input)\"",
}},
}},
}},
},
},
}, {
name: "valid pipeline with pipeline task and final task referencing artifacts in task params with enable-artifacts flag true",
p: &Pipeline{
Expand Down
Loading