KEP-29: instance controller reconciliation for parent instances (#1555)

pkg/apis/kudo/v1beta1/instance_types.go

@@ -182,12 +182,12 @@ var (
 	}
 )
 
-// IsTerminal returns true if the status is terminal (either complete, or in a nonrecoverable error)
+// IsTerminal returns true if the status is terminal (either complete, or in a fatal error)
 func (s ExecutionStatus) IsTerminal() bool {
 	return s == ExecutionComplete || s == ExecutionFatalError
 }
 
-// IsFinished returns true if the status is complete regardless of errors
+// IsFinished returns true if the status is complete successfully (not in 'FATAL_ERROR' state)
 func (s ExecutionStatus) IsFinished() bool {
 	return s == ExecutionComplete
 }

pkg/apis/kudo/v1beta1/instance_types_helpers.go

@@ -208,19 +208,6 @@ func wasRunAfter(p1 PlanStatus, p2 PlanStatus) bool {
 	return p1.LastUpdatedTimestamp.Time.After(p2.LastUpdatedTimestamp.Time)
 }
 
-// GetExistingParamDefinitions retrieves parameter metadata from OperatorVersion
-func GetExistingParamDefinitions(params map[string]string, ov *OperatorVersion) []Parameter {
-	defs := []Parameter{}
-	for p1 := range params {
-		for _, p2 := range ov.Spec.Parameters {
-			if p2.Name == p1 {
-				defs = append(defs, p2)
-			}
-		}
-	}
-	return defs
-}
-
 // GetParamDefinitions retrieves parameter metadata from OperatorVersion but returns an error if any parameter is missing
 func GetParamDefinitions(params map[string]string, ov *OperatorVersion) ([]Parameter, error) {
 	defs := []Parameter{}

pkg/controller/instance/instance_controller.go

@@ -175,6 +175,7 @@ func (r *Reconciler) Reconcile(request ctrl.Request) (ctrl.Result, error) {
 	}
 
 	// ---------- 2. Get currently scheduled plan if it exists ----------
+
 	// get the scheduled plan
 	plan, uid := scheduledPlan(instance, ov)
 	if plan == "" {

pkg/engine/task/task_kudo_operator.go

@@ -137,7 +137,7 @@ func instanceResource(instanceName, operatorName, operatorVersionName, namespace
 		},
 		Status: v1beta1.InstanceStatus{},
 	}
-	if err := controllerutil.SetControllerReference(owner, instance, scheme); err != nil {
+	if err := controllerutil.SetOwnerReference(owner, instance, scheme); err != nil {
 		return nil, fmt.Errorf("failed to set resource ownership for the new instance: %v", err)
 	}
 

test/integration/operator-with-dependencies/01-assert.yaml

@@ -1,5 +1,15 @@
 apiVersion: kudo.dev/v1beta1
 kind: Instance
+metadata:
+  name: dummy-instance
+status:
+  planStatus:
+    deploy:
+      status: COMPLETE
+
+---
+apiVersion: kudo.dev/v1beta1
+kind: Instance
 metadata:
   name: dummy-instance.child
 status: