Function processTaskCompletedStatus

acceptance/kubernetes/kubernetes.go:268–288

(ctx context.Context, want bool)

}

func processTaskCompletedStatus(ctx context.Context, want bool) error {
	c := testenv.FetchState[ClusterState](ctx)

	if err := mustBeUp(ctx, *c); err != nil {
		return err
	}

	got, err := c.cluster.AwaitUntilTaskIsDone(ctx)
	if err != nil {
		return err
	}

	if got != want {
		if err := logTaskOutput(ctx, *c); err != nil {
			return err
		}
		return fmt.Errorf("the TaskRun did not complete as expected: want=%v, got=%v", want, got)
	}

	return nil
}

func logTaskOutput(ctx context.Context, c ClusterState) error {
	info, err := c.cluster.TaskInfo(ctx)