WIP:

examples/pipelineruns/pipelinerun-conditional-setup.yaml

@@ -39,8 +39,7 @@ spec:
       taskRef:
         name: list-files
         conditions:
-          - name:
-            conditionRef: stringsEqual
+          - conditionRef: stringsEqual
             params:
               - name: expected
                 value: master

examples/pipelineruns/pipelinerun.yaml

@@ -7,7 +7,7 @@ spec:
   type: image
   params:
   - name: url
-    value: gcr.io/christiewilson-catfactory/leeroy-app
+    value: gcr.io/dibyo-spinnaker-dev/leeroy-app
 ---
 # This demo modifies the cluster (deploys to it) you must use a service
 # account with permission to admin the cluster (or make your default user an admin
@@ -34,7 +34,7 @@ spec:
   type: image
   params:
   - name: url
-    value: gcr.io/christiewilson-catfactory/leeroy-web
+    value: gcr.io/dibyo-spinnaker-dev/leeroy-web
 ---
 apiVersion: tekton.dev/v1alpha1
 kind: PipelineResource

pkg/apis/pipeline/v1alpha1/condition_types.go

@@ -1,17 +1,50 @@
 package v1alpha1
 
+import(
+	"github.com/knative/pkg/apis"
+	corev1 "k8s.io/api/core/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
 // Add validation for TaskConditions?
 type TaskCondition struct {
-	Name string `json:"name"`
-	// TODO: ref should probably be its own type with kind + version
 	ConditionRef string `json:"conditionRef"`
 	// +optional
 	Params []Param `json:"params,omitempty"`
 }
 
+// Check that Task may be validated and defaulted.
+var _ apis.Validatable = (*Task)(nil)
+var _ apis.Defaultable = (*Task)(nil)
 
 
+// Task represents a collection of sequential steps that are run as part of a
+// Pipeline using a set of inputs and producing a set of outputs. Tasks execute
+// when TaskRuns are created that provide the input parameters and resources and
+// output resources the Task requires.
+//
+// +k8s:openapi-gen=true
 type Condition struct {
+	metav1.TypeMeta `json:",inline"`
+	// +optional
+	metav1.ObjectMeta `json:"metadata"`
+
+	// Spec holds the desired state of the Condition from the client
+	// +optional
+	Spec ConditionSpec `json:"spec"`
+	// +optional
+	Status TaskRunStatus `json:"status,omitempty"`
+}
+
+type ConditionSpec struct {
+	// +optional
+	Params []Param `json:"params,omitempty"`
+  // Check is a container whose exit code determines where a condition is true or false
+	Check *corev1.Container `json:"check,omitempty"`
+}
 
+type ConditionState struct {
+	corev1.ContainerState
+	Name string `json:"name,omitempty"`
 }
 

pkg/reconciler/v1alpha1/pipelinerun/pipelinerun.go

@@ -514,8 +514,8 @@ func (c *Reconciler) createTaskRun(logger *zap.SugaredLogger, rprt *resources.Re
 			NodeSelector:   pr.Spec.NodeSelector,
 			Tolerations:    pr.Spec.Tolerations,
 			Affinity:       pr.Spec.Affinity,
-		},
-	}
+			Conditions:     rprt.PipelineTask.Conditions, // TODO: Validate + Resolve conditionRef
+		}}
 
 	resources.WrapSteps(&tr.Spec, rprt.PipelineTask, rprt.ResolvedTaskResources.Inputs, rprt.ResolvedTaskResources.Outputs, storageBasePath)