Function logTaskOutput

acceptance/kubernetes/kubernetes.go:290–339

(ctx context.Context, c ClusterState)

}

func logTaskOutput(ctx context.Context, c ClusterState) error {
	info, err := c.cluster.TaskInfo(ctx)
	if err != nil {
		return err
	}

	noColors := testenv.NoColorOutput(ctx)
	if clr.SUPPORT_COLOR != !noColors {
		clr.SUPPORT_COLOR = !noColors
	}

	output := &strings.Builder{}
	outputSegment := func(name string, v any) {
		output.WriteString("\n\n")
		output.WriteString(clr.Underline(clr.Bold(name)))
		output.WriteString(fmt.Sprintf("\n%v", v))
	}

	var buffy bytes.Buffer
	w := tabwriter.NewWriter(&buffy, 10, 1, 2, ' ', 0)

	fmt.Fprintf(w, "%s\t%s\n", clr.Bold("Namespace"), info.Namespace)
	fmt.Fprintf(w, "%s\t%s\n", clr.Bold("TaskRunName2"), info.Name)
	fmt.Fprintf(w, "%s\t%s", clr.Bold("Status"), info.Status)
	w.Flush()
	outputSegment("TaskRun", buffy.String())

	buffy.Reset()
	fmt.Fprintf(w, "%s\t%s\n", clr.Bold("Name"), clr.Bold("Value"))
	for n, v := range info.Params {
		fmt.Fprintf(w, "%s\t%v\n", n, v)
	}
	w.Flush()
	outputSegment("Parameters", buffy.String())

	buffy.Reset()
	for _, step := range info.Steps {
		outputSegment(fmt.Sprintf("Step \"%s\"", clr.Bold(step.Name)), fmt.Sprintf("%s  %s\n----- Logs -----\n%s\n----- /Logs -----", clr.Bold("Status"), step.Status, step.Logs))
	}
	w.Flush()

	// TODO, when the task fails and test state is persisted add some debugging
	// lines here to help debug, e.g. `export
	// KUBECONFIG=$TMPDIR/ec-acceptance.../kubeconfig`, set the current
	// namespace with: `kubectl config set-context --current --namespace
	// acceptance-...`

	fmt.Println(output)
	return nil
}

func taskLogsShouldMatchTheSnapshot(ctx context.Context, stepName string) error {
	c := testenv.FetchState[ClusterState](ctx)