Migration resource is created

pkg/controller/migration/objects.go

@@ -8,7 +8,6 @@ import (
 	schemasv1alpha3 "github.com/schemahero/schemahero/pkg/apis/schemas/v1alpha3"
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	"sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
 )
 
 func (r *ReconcileMigration) applyPod(database *databasesv1alpha3.Database, table *schemasv1alpha3.Table) (*corev1.Pod, error) {
@@ -105,9 +104,6 @@ func (r *ReconcileMigration) applyPod(database *databasesv1alpha3.Database, tabl
 			},
 		},
 	}
-	if err := controllerutil.SetControllerReference(table, pod, r.scheme); err != nil {
-		return nil, errors.Wrap(err, "failed to set controller ref")
-	}
 
 	return pod, nil
 }

pkg/controller/table/objects.go

@@ -12,7 +12,6 @@ import (
 	kuberneteserrors "k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/types"
-	"sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
 )
 
 func (r *ReconcileTable) planConfigMap(database *databasesv1alpha3.Database, table *schemasv1alpha3.Table) (*corev1.ConfigMap, error) {
@@ -134,9 +133,6 @@ func (r *ReconcileTable) planPod(database *databasesv1alpha3.Database, table *sc
 			},
 		},
 	}
-	if err := controllerutil.SetControllerReference(table, pod, r.scheme); err != nil {
-		return nil, errors.Wrap(err, "failed to set controller ref")
-	}
 
 	return pod, nil
 }

pkg/controller/table/plan.go

@@ -19,7 +19,6 @@ import (
 	"k8s.io/apimachinery/pkg/types"
 	"k8s.io/client-go/kubernetes"
 	"sigs.k8s.io/controller-runtime/pkg/client/config"
-	"sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
 	"sigs.k8s.io/controller-runtime/pkg/reconcile"
 )
 
@@ -129,13 +128,31 @@ func (r *ReconcileTable) reconcilePod(pod *corev1.Pod) (reconcile.Result, error)
 
 	// Delete the pod and config map
 	if err := r.Delete(context.Background(), pod); err != nil {
-		return reconcile.Result{}, err
+		return reconcile.Result{}, errors.Wrap(err, "failed to delete pod from plan phase")
+	}
+
+	configMapName := ""
+	for _, volume := range pod.Spec.Volumes {
+		if volume.Name == "specs" && volume.ConfigMap != nil {
+			configMapName = volume.ConfigMap.Name
+		}
+	}
+	configMap := corev1.ConfigMap{}
+	err = r.Get(context.Background(), types.NamespacedName{Name: configMapName, Namespace: pod.Namespace}, &configMap)
+	if err != nil {
+		return reconcile.Result{}, errors.Wrap(err, "failed to get config map from plan phase")
+	}
+
+	if err := r.Delete(context.Background(), &configMap); err != nil {
+		return reconcile.Result{}, errors.Wrap(err, "failed to delete config map from plan phase")
 	}
 
 	return reconcile.Result{}, nil
 }
 
 func (r *ReconcileTable) plan(database *databasesv1alpha3.Database, table *schemasv1alpha3.Table) error {
+	logger.Debug("deploying plan")
+
 	configMap, err := r.planConfigMap(database, table)
 	if err != nil {
 		return errors.Wrap(err, "failed to get config map object for plan")
@@ -145,10 +162,6 @@ func (r *ReconcileTable) plan(database *databasesv1alpha3.Database, table *schem
 		return errors.Wrap(err, "failed to get pod for plan")
 	}
 
-	if err := controllerutil.SetControllerReference(pod, configMap, r.scheme); err != nil {
-		return errors.Wrap(err, "failed to set controller reference")
-	}
-
 	if err := r.ensureTableConfigMap(configMap); err != nil {
 		return errors.Wrap(err, "failed to create config map for plan")
 	}

pkg/controller/table/table_controller.go

@@ -18,6 +18,7 @@ package table
 
 import (
 	"context"
+	"fmt"
 	"time"
 
 	"github.com/pkg/errors"
@@ -103,6 +104,7 @@ type ReconcileTable struct {
 func (r *ReconcileTable) Reconcile(request reconcile.Request) (reconcile.Result, error) {
 	instance, instanceErr := r.getInstance(request)
 	if instanceErr == nil {
+		fmt.Printf("instance\n")
 		result, err := r.reconcileInstance(instance)
 		if err != nil {
 			logger.Error(err)