From 5c297accd3b86b4163f823a9d42b1f1268dcc56f Mon Sep 17 00:00:00 2001 From: pvito Date: Fri, 8 Jul 2022 22:28:33 +0200 Subject: [PATCH] Skip existing cluster check for now. --- pkg/controller/actuator.go | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/pkg/controller/actuator.go b/pkg/controller/actuator.go index 5e9efa4..dfc1fa7 100644 --- a/pkg/controller/actuator.go +++ b/pkg/controller/actuator.go @@ -214,14 +214,14 @@ func (a *actuator) ReconcileClusterInFleetManager(ctx context.Context, namespace a.logger.Error(err, "Failed to find Secret with kubeconfig for Fleet registration.") return err } - // skip this check for now - // a.logger.Info("Checking if the fleet cluster already exists") + + a.logger.Info("Checking if the fleet cluster already exists") // Check whether we already have an existing cluster - //_, err := a.getFleetManager(cluster).GetCluster(ctx, buildCrdName(cluster)) - //if err != nil { - // a.logger.Error(err, "Could not fetch fleet cluster") - // return err - //} + _, err := a.getFleetManager(cluster).GetCluster(ctx, buildCrdName(cluster)) + if err != nil { + a.logger.Error(err, "Could not fetch fleet cluster") + //return err + } // We cannot find the cluster because of an unknown error if err != nil && !errors.IsNotFound(err) {