Add flag to prefix log lines with log source (task and step name) by default

docs/cmd/tkn_pipeline_logs.md

@@ -40,6 +40,7 @@ Show logs for given Pipeline and PipelineRun:
   -h, --help         help for logs
   -L, --last         show logs for last PipelineRun
       --limit int    lists number of PipelineRuns (default 5)
+      --prefix       prefix each log line with the log source (task name and step name) (default true)
   -t, --timestamps   show logs with timestamp
 ```
 

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

@@ -39,6 +39,10 @@ Show Pipeline logs
 \fB\-\-limit\fP=5
     lists number of PipelineRuns
 
+.PP
+\fB\-\-prefix\fP[=true]
+    prefix each log line with the log source (task name and step name)
+
 .PP
 \fB\-t\fP, \fB\-\-timestamps\fP[=false]
     show logs with timestamp

pkg/cmd/pipeline/logs.go

@@ -97,6 +97,7 @@ Show logs for given Pipeline and PipelineRun:
 	c.Flags().BoolVarP(&opts.Follow, "follow", "f", false, "stream live logs")
 	c.Flags().BoolVarP(&opts.Timestamps, "timestamps", "t", false, "show logs with timestamp")
 	c.Flags().IntVarP(&opts.Limit, "limit", "", 5, "lists number of PipelineRuns")
+	c.Flags().BoolVarP(&opts.Prefixing, "prefix", "", true, "prefix each log line with the log source (task name and step name)")
 
 	return c
 }

pkg/cmd/pipeline/logs_test.go

@@ -265,6 +265,24 @@ func TestPipelineLog_v1beta1(t *testing.T) {
 			wantError: false,
 			want:      "",
 		},
+		{
+			name:      "Logs with prefix enabled (default)",
+			command:   []string{"logs", pipelineName, "-n", ns, "-L"},
+			namespace: ns,
+			dynamic:   dc3,
+			input:     cs3,
+			wantError: false,
+			want:      "",
+		},
+		{
+			name:      "Logs with prefix disabled",
+			command:   []string{"logs", pipelineName, "-n", ns, "--last", "--prefix=false"},
+			namespace: ns,
+			dynamic:   dc3,
+			input:     cs3,
+			wantError: false,
+			want:      "",
+		},
 	}
 
 	for _, tp := range testParams {
@@ -502,6 +520,24 @@ func TestPipelineLog(t *testing.T) {
 			wantError: false,
 			want:      "",
 		},
+		{
+			name:      "Logs with prefix enabled (default)",
+			command:   []string{"logs", pipelineName, "-n", ns, "-L"},
+			namespace: ns,
+			dynamic:   dc3,
+			input:     cs3,
+			wantError: false,
+			want:      "",
+		},
+		{
+			name:      "Logs with prefix disabled",
+			command:   []string{"logs", pipelineName, "-n", ns, "--last", "--prefix=false"},
+			namespace: ns,
+			dynamic:   dc3,
+			input:     cs3,
+			wantError: false,
+			want:      "",
+		},
 	}
 
 	for _, tp := range testParams {

test/e2e/pipeline/start_test.go

@@ -78,7 +78,7 @@ func TestPipelineInteractiveStartE2E(t *testing.T) {
 	})
 
 	t.Run("Validate pipeline logs, with  follow mode (-f) and --last ", func(t *testing.T) {
-		res := tkn.Run(t, "pipeline", "logs", "--last", "-f")
+		res := tkn.Run(t, "pipeline", "logs", "--last", "-f", "--prefix=false")
 		expected := "\n\ntest-e2e\n\n"
 		helper.AssertOutput(t, expected, res.Stdout())
 	})