pipeline start supports taskRunSpec argument

docs/cmd/tkn_pipeline_start.md

@@ -77,6 +77,7 @@ my-secret, my-empty-dir and my-volume-claim-template)
   -s, --serviceaccount string         pass the serviceaccount name
       --showlog                       show logs right after starting the Pipeline
       --skip-optional-workspace       skips the prompt for optional workspaces
+      --task-run-spec string          local or remote file containing a TaskRunSpec definition
       --task-serviceaccount strings   pass the service account corresponding to the task
       --tasks-timeout string          timeout for Pipeline TaskRuns
       --use-param-defaults            use default parameter values without prompting for input

docs/man/man1/tkn-pipeline-start.1

@@ -83,6 +83,10 @@ Parameters, at least those that have no default value
 \fB\-\-skip\-optional\-workspace\fP[=false]
     skips the prompt for optional workspaces
 
+.PP
+\fB\-\-task\-run\-spec\fP=""
+    local or remote file containing a TaskRunSpec definition
+
 .PP
 \fB\-\-task\-serviceaccount\fP=[]
     pass the service account corresponding to the task

pkg/cmd/pipeline/start.go

@@ -85,6 +85,7 @@ type startOptions struct {
 	UseParamDefaults      bool
 	TektonOptions         flags.TektonOptions
 	PodTemplate           string
+	TaskRunSpec           string
 	SkipOptionalWorkspace bool
 }
 
@@ -206,6 +207,7 @@ For passing the workspaces via flags:
 	c.Flags().StringVarP(&opt.Filename, "filename", "f", "", "local or remote file name containing a Pipeline definition to start a PipelineRun")
 	c.Flags().BoolVarP(&opt.UseParamDefaults, "use-param-defaults", "", false, "use default parameter values without prompting for input")
 	c.Flags().StringVar(&opt.PodTemplate, "pod-template", "", "local or remote file containing a PodTemplate definition")
+	c.Flags().StringVar(&opt.TaskRunSpec, "task-run-spec", "", "local or remote file containing a TaskRunSpec definition")
 	c.Flags().BoolVarP(&opt.SkipOptionalWorkspace, "skip-optional-workspace", "", false, "skips the prompt for optional workspaces")
 
 	c.Flags().StringVarP(&opt.ServiceAccountName, "serviceaccount", "s", "", "pass the serviceaccount name")
@@ -355,6 +357,15 @@ func (opt *startOptions) startPipeline(pipelineStart *v1beta1.Pipeline) error {
 		pr.Spec.PodTemplate = &podTemplate
 	}
 
+	taskRunSpecLocation := opt.TaskRunSpec
+	if taskRunSpecLocation != "" {
+		taskRunSpec, err := pods.ParseTaskRunSpec(cs.HTTPClient, taskRunSpecLocation, file.IsYamlFile(), fmt.Errorf("invalid file format for %s: .yaml or .yml file extension and format required", taskRunSpecLocation))
+		if err != nil {
+			return err
+		}
+		pr.Spec.TaskRunSpecs = taskRunSpec
+	}
+
 	if opt.DryRun {
 		format := strings.ToLower(opt.Output)
 		if format == "name" {

pkg/cmd/pipeline/start_test.go

@@ -1010,6 +1010,25 @@ func TestPipelineStart_ExecuteCommand_v1beta1(t *testing.T) {
 			wantError:  false,
 			goldenFile: true,
 		},
+
+		{
+			name: "Dry Run with TaskRunSpec",
+			command: []string{
+				"start", "test-pipeline",
+				"-s=svc1",
+				"-r=source=scaffold-git",
+				"-p=pipeline-param=value1",
+				"-p=rev-param=value2",
+				"-l=jemange=desfrites",
+				"-n", "ns",
+				"--dry-run",
+				"--task-run-spec", "./testdata/taskrunspec.yaml",
+			},
+			namespace:  "",
+			input:      c2,
+			wantError:  false,
+			goldenFile: true,
+		},
 	}
 
 	for _, tp := range testParams {

pkg/cmd/pipeline/start_v1_test.go

@@ -855,6 +855,24 @@ func TestPipelineStart_ExecuteCommand(t *testing.T) {
 			wantError:  false,
 			goldenFile: true,
 		},
+
+		{
+			name: "Dry Run with TaskRunSpec",
+			command: []string{
+				"start", "test-pipeline",
+				"-s=svc1",
+				"-p=pipeline-param=value1",
+				"-p=rev-param=value2",
+				"-l=jemange=desfrites",
+				"-n", "ns",
+				"--dry-run",
+				"--task-run-spec", "./testdata/taskrunspec.yaml",
+			},
+			namespace:  "",
+			input:      c2,
+			wantError:  false,
+			goldenFile: true,
+		},
 	}
 
 	for _, tp := range testParams {

pkg/cmd/pipeline/testdata/TestPipelineStart_ExecuteCommand-Dry_Run_with_TaskRunSpec.golden

@@ -0,0 +1,26 @@
+apiVersion: tekton.dev/v1
+kind: PipelineRun
+metadata:
+  creationTimestamp: null
+  generateName: test-pipeline-run-
+  labels:
+    jemange: desfrites
+  namespace: ns
+spec:
+  params:
+  - name: pipeline-param
+    value: value1
+  - name: rev-param
+    value: value2
+  pipelineRef:
+    name: test-pipeline
+  taskRunSpecs:
+  - pipelineTaskName: unit-test-task
+    podTemplate:
+      schedulerName: SchedulerName
+      securityContext:
+        runAsNonRoot: true
+        runAsUser: 1001
+  taskRunTemplate:
+    serviceAccountName: svc1
+status: {}

pkg/cmd/pipeline/testdata/TestPipelineStart_ExecuteCommand_v1beta1-Dry_Run_with_TaskRunSpec.golden

@@ -0,0 +1,30 @@
+Flag --resource has been deprecated, pipelineresources have been deprecated, this flag will be removed soon
+apiVersion: tekton.dev/v1beta1
+kind: PipelineRun
+metadata:
+  creationTimestamp: null
+  generateName: test-pipeline-run-
+  labels:
+    jemange: desfrites
+  namespace: ns
+spec:
+  params:
+  - name: pipeline-param
+    value: value1
+  - name: rev-param
+    value: value2
+  pipelineRef:
+    name: test-pipeline
+  resources:
+  - name: source
+    resourceRef:
+      name: scaffold-git
+  serviceAccountName: svc1
+  taskRunSpecs:
+  - pipelineTaskName: unit-test-task
+    taskPodTemplate:
+      schedulerName: SchedulerName
+      securityContext:
+        runAsNonRoot: true
+        runAsUser: 1001
+status: {}

pkg/cmd/pipeline/testdata/taskrunspec.yaml

@@ -0,0 +1,6 @@
+- pipelineTaskName: unit-test-task
+  taskPodTemplate:
+    schedulerName: SchedulerName
+    securityContext:
+      runAsNonRoot: true
+      runAsUser: 1001

pkg/pods/pod_template.go

@@ -19,6 +19,7 @@ import (
 
 	"github.com/tektoncd/cli/pkg/file"
 	"github.com/tektoncd/pipeline/pkg/apis/pipeline/pod"
+	"github.com/tektoncd/pipeline/pkg/apis/pipeline/v1beta1"
 	"sigs.k8s.io/yaml"
 )
 
@@ -35,3 +36,19 @@ func ParsePodTemplate(httpClient http.Client, podTemplateLocation string, valida
 
 	return podTemplate, nil
 }
+
+type TaskRunSpec = []v1beta1.PipelineTaskRunSpec
+
+func ParseTaskRunSpec(httpClient http.Client, taskRunSpecLocation string, validate file.TypeValidator, errorMsg error) (TaskRunSpec, error) {
+	taskRunSpec := TaskRunSpec{}
+	b, err := file.LoadFileContent(httpClient, taskRunSpecLocation, validate, errorMsg)
+	if err != nil {
+		return taskRunSpec, err
+	}
+
+	if err := yaml.UnmarshalStrict(b, &taskRunSpec); err != nil {
+		return taskRunSpec, err
+	}
+
+	return taskRunSpec, nil
+}

test/e2e/pipeline/pipeline_test.go

@@ -305,6 +305,23 @@ Waiting for logs to be available...
 		}
 	})
 
+	t.Run("Start PipelineRun with --task-run-spec", func(t *testing.T) {
+		tkn.MustSucceed(t, "pipeline", "start", tePipelineName,
+			"-p=filename=output",
+			"-w=name=shared-data,emptyDir=",
+			"--task-run-spec="+helper.GetResourcePath("/taskrunspec/taskrunspec.yaml"),
+			"--use-param-defaults",
+			"--showlog")
+
+		time.Sleep(1 * time.Second)
+
+		pipelineRunGeneratedName := builder.GetPipelineRunListWithName(c, tePipelineName, true).Items[0].Name
+		timeout := 5 * time.Minute
+		if err := wait.ForPipelineRunState(c, pipelineRunGeneratedName, timeout, wait.PipelineRunSucceed(pipelineRunGeneratedName), "PipelineRunSucceeded"); err != nil {
+			t.Errorf("Error waiting for PipelineRun to Succeed: %s", err)
+		}
+	})
+
 	t.Run("Cancel finished PipelineRun with tkn pipelinerun cancel", func(t *testing.T) {
 		// Get last PipelineRun for pipeline-with-workspace
 		pipelineRunLast := builder.GetPipelineRunListWithName(c, tePipelineName, true).Items[0]

test/resources/taskrunspec.yaml

@@ -0,0 +1,6 @@
+- pipelineTaskName: first-create-file
+  taskPodTemplate:
+    schedulerName: SchedulerName
+    securityContext:
+      runAsNonRoot: true
+      runAsUser: 1001