Use v1beta1 in controllers 🍸

- switch storage to v1beta1 for CRDs (config/)
- use v1beta1 in controllers, …

Signed-off-by: Vincent Demeester <[email protected]>

Author: vdemeester

config/300-clustertask.yaml

@@ -36,10 +36,10 @@ spec:
   versions:
   - name: v1alpha1
     served: true
-    storage: true
+    storage: false
   - name: v1beta1
     served: true
-    storage: false
+    storage: true
   names:
     kind: ClusterTask
     plural: clustertasks

config/300-pipeline.yaml

@@ -36,10 +36,10 @@ spec:
   versions:
   - name: v1alpha1
     served: true
-    storage: true
+    storage: false
   - name: v1beta1
     served: true
-    storage: false
+    storage: true
   names:
     kind: Pipeline
     plural: pipelines

config/300-pipelinerun.yaml

@@ -36,10 +36,10 @@ spec:
   versions:
   - name: v1alpha1
     served: true
-    storage: true
+    storage: false
   - name: v1beta1
     served: true
-    storage: false
+    storage: true
   names:
     kind: PipelineRun
     plural: pipelineruns

config/300-task.yaml

@@ -36,10 +36,10 @@ spec:
   versions:
   - name: v1alpha1
     served: true
-    storage: true
+    storage: false
   - name: v1beta1
     served: true
-    storage: false
+    storage: true
   names:
     kind: Task
     plural: tasks

config/300-taskrun.yaml

@@ -36,10 +36,10 @@ spec:
   versions:
   - name: v1alpha1
     served: true
-    storage: true
+    storage: false
   - name: v1beta1
     served: true
-    storage: false
+    storage: true
   names:
     kind: TaskRun
     plural: taskruns

internal/builder/v1alpha1/task.go

@@ -22,7 +22,6 @@ import (
 	"github.com/tektoncd/pipeline/pkg/apis/config"
 	"github.com/tektoncd/pipeline/pkg/apis/pipeline/v1alpha1"
 	"github.com/tektoncd/pipeline/pkg/apis/pipeline/v1beta1"
-	"github.com/tektoncd/pipeline/pkg/reconciler/taskrun/resources"
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"knative.dev/pkg/apis"
@@ -76,9 +75,6 @@ type TaskRunInputsOp func(*v1alpha1.TaskRunInputs)
 // TaskRunOutputsOp is an operation which modify a TaskRunOutputs struct.
 type TaskRunOutputsOp func(*v1alpha1.TaskRunOutputs)
 
-// ResolvedTaskResourcesOp is an operation which modify a ResolvedTaskResources struct.
-type ResolvedTaskResourcesOp func(*resources.ResolvedTaskResources)
-
 // StepStateOp is an operation which modifies a StepState struct.
 type StepStateOp func(*v1alpha1.StepState)
 
@@ -932,45 +928,3 @@ func TaskRunWorkspaceVolumeClaimTemplate(name, subPath string, volumeClaimTempla
 		})
 	}
 }
-
-// ResolvedTaskResources creates a ResolvedTaskResources with default values.
-// Any number of ResolvedTaskResources modifier can be passed to transform it.
-func ResolvedTaskResources(ops ...ResolvedTaskResourcesOp) *resources.ResolvedTaskResources {
-	resources := &resources.ResolvedTaskResources{}
-	for _, op := range ops {
-		op(resources)
-	}
-	return resources
-}
-
-// ResolvedTaskResourcesTaskSpec sets a TaskSpec to the ResolvedTaskResources.
-// Any number of TaskSpec modifier can be passed to transform it.
-func ResolvedTaskResourcesTaskSpec(ops ...TaskSpecOp) ResolvedTaskResourcesOp {
-	return func(r *resources.ResolvedTaskResources) {
-		spec := &v1alpha1.TaskSpec{}
-		for _, op := range ops {
-			op(spec)
-		}
-		r.TaskSpec = spec
-	}
-}
-
-// ResolvedTaskResourcesInputs adds an input PipelineResource, with specified name, to the ResolvedTaskResources.
-func ResolvedTaskResourcesInputs(name string, resource *v1alpha1.PipelineResource) ResolvedTaskResourcesOp {
-	return func(r *resources.ResolvedTaskResources) {
-		if r.Inputs == nil {
-			r.Inputs = map[string]*v1alpha1.PipelineResource{}
-		}
-		r.Inputs[name] = resource
-	}
-}
-
-// ResolvedTaskResourcesOutputs adds an output PipelineResource, with specified name, to the ResolvedTaskResources.
-func ResolvedTaskResourcesOutputs(name string, resource *v1alpha1.PipelineResource) ResolvedTaskResourcesOp {
-	return func(r *resources.ResolvedTaskResources) {
-		if r.Outputs == nil {
-			r.Outputs = map[string]*v1alpha1.PipelineResource{}
-		}
-		r.Outputs[name] = resource
-	}
-}

internal/builder/v1alpha1/task_test.go

@@ -25,7 +25,6 @@ import (
 	"github.com/tektoncd/pipeline/pkg/apis/config"
 	"github.com/tektoncd/pipeline/pkg/apis/pipeline/v1alpha1"
 	"github.com/tektoncd/pipeline/pkg/apis/pipeline/v1beta1"
-	"github.com/tektoncd/pipeline/pkg/reconciler/taskrun/resources"
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"knative.dev/pkg/apis"
@@ -421,40 +420,3 @@ func TestTaskRunWithPodTemplate(t *testing.T) {
 		t.Fatalf("TaskRun diff -want, +got: %v", d)
 	}
 }
-
-func TestResolvedTaskResources(t *testing.T) {
-	resolvedTaskResources := tb.ResolvedTaskResources(
-		tb.ResolvedTaskResourcesTaskSpec(
-			tb.Step("image", tb.StepCommand("/mycmd")),
-		),
-		tb.ResolvedTaskResourcesInputs("foo", tb.PipelineResource("bar", tb.PipelineResourceNamespace("baz"))),
-		tb.ResolvedTaskResourcesOutputs("qux", tb.PipelineResource("quux", tb.PipelineResourceNamespace("quuz"))),
-	)
-	expectedResolvedTaskResources := &resources.ResolvedTaskResources{
-		TaskSpec: &v1alpha1.TaskSpec{TaskSpec: v1beta1.TaskSpec{
-			Steps: []v1alpha1.Step{{Container: corev1.Container{
-				Image:   "image",
-				Command: []string{"/mycmd"},
-			}}},
-		}},
-		Inputs: map[string]*v1alpha1.PipelineResource{
-			"foo": {
-				ObjectMeta: metav1.ObjectMeta{
-					Name:      "bar",
-					Namespace: "baz",
-				},
-			},
-		},
-		Outputs: map[string]*v1alpha1.PipelineResource{
-			"qux": {
-				ObjectMeta: metav1.ObjectMeta{
-					Name:      "quux",
-					Namespace: "quuz",
-				},
-			},
-		},
-	}
-	if d := cmp.Diff(expectedResolvedTaskResources, resolvedTaskResources); d != "" {
-		t.Fatalf("ResolvedTaskResources diff -want, +got: %v", d)
-	}
-}

internal/builder/v1beta1/pipeline_test.go

@@ -302,7 +302,7 @@ func TestPipelineRunWithResourceSpec(t *testing.T) {
 		tb.PipelineRunResourceBinding("some-resource",
 			tb.PipelineResourceBindingResourceSpec(&resource.PipelineResourceSpec{
 				Type: v1beta1.PipelineResourceTypeGit,
-				Params: []v1beta1.ResourceParam{{
+				Params: []resource.ResourceParam{{
 					Name:  "url",
 					Value: "git",
 				}}})),
@@ -339,7 +339,7 @@ func TestPipelineRunWithResourceSpec(t *testing.T) {
 				Name: "some-resource",
 				ResourceSpec: &resource.PipelineResourceSpec{
 					Type: v1beta1.PipelineResourceType("git"),
-					Params: []v1beta1.ResourceParam{{
+					Params: []resource.ResourceParam{{
 						Name:  "url",
 						Value: "git",
 					}},

internal/builder/v1beta1/resource_test.go

@@ -35,7 +35,7 @@ func TestPipelineResource(t *testing.T) {
 		Spec: resource.PipelineResourceSpec{
 			Description: "test description",
 			Type:        v1beta1.PipelineResourceTypeGit,
-			Params: []v1beta1.ResourceParam{{
+			Params: []resource.ResourceParam{{
 				Name: "URL", Value: "https://foo.git",
 			}},
 		},

pkg/apis/pipeline/v1beta1/condition_types.go

@@ -19,9 +19,32 @@ package v1beta1
 import (
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"knative.dev/pkg/apis"
 	duckv1beta1 "knative.dev/pkg/apis/duck/v1beta1"
 )
 
+// ConditionCheck represents a single evaluation of a Condition step.
+type ConditionCheck TaskRun
+
+func NewConditionCheck(tr *TaskRun) *ConditionCheck {
+	if tr == nil {
+		return nil
+	}
+
+	cc := ConditionCheck(*tr)
+	return &cc
+}
+
+// IsDone returns true if the ConditionCheck's status indicates that it is done.
+func (cc *ConditionCheck) IsDone() bool {
+	return !cc.Status.GetCondition(apis.ConditionSucceeded).IsUnknown()
+}
+
+// IsSuccessful returns true if the ConditionCheck's status indicates that it is done.
+func (cc *ConditionCheck) IsSuccessful() bool {
+	return cc.Status.GetCondition(apis.ConditionSucceeded).IsTrue()
+}
+
 // ConditionCheckStatus defines the observed state of ConditionCheck
 type ConditionCheckStatus struct {
 	duckv1beta1.Status `json:",inline"`