Skip to content

Commit

Permalink
fix: disable override controllers for debugging purposes (#784)
Browse files Browse the repository at this point in the history
  • Loading branch information
michaelawyu authored Apr 28, 2024
1 parent f72a65a commit a17837e
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 22 deletions.
22 changes: 0 additions & 22 deletions cmd/hubagent/workload/setup.go
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,6 @@ import (
"go.goms.io/fleet/pkg/controllers/clusterresourceplacementwatcher"
"go.goms.io/fleet/pkg/controllers/clusterschedulingpolicysnapshot"
"go.goms.io/fleet/pkg/controllers/memberclusterplacement"
"go.goms.io/fleet/pkg/controllers/overrider"
"go.goms.io/fleet/pkg/controllers/resourcechange"
"go.goms.io/fleet/pkg/controllers/rollout"
"go.goms.io/fleet/pkg/controllers/workgenerator"
Expand Down Expand Up @@ -287,27 +286,6 @@ func SetupControllers(ctx context.Context, wg *sync.WaitGroup, mgr ctrl.Manager,
klog.ErrorS(err, "Unable to set up memberCluster watcher for scheduler")
return err
}

// setup override related controllers
klog.Info("Setting up the clusterResourceOverride controller")
if err := (&overrider.ClusterResourceReconciler{
Reconciler: overrider.Reconciler{
Client: mgr.GetClient(),
},
}).SetupWithManager(mgr); err != nil {
klog.ErrorS(err, "Unable to set up clusterResourceOverride controller")
return err
}

klog.Info("Setting up the resourceOverride controller")
if err := (&overrider.ResourceReconciler{
Reconciler: overrider.Reconciler{
Client: mgr.GetClient(),
},
}).SetupWithManager(mgr); err != nil {
klog.ErrorS(err, "Unable to set up resourceOverride controller")
return err
}
}

// Set up a runner that starts all the custom controllers we created above
Expand Down
2 changes: 2 additions & 0 deletions test/e2e/placement_cro_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@ var _ = Describe("creating clusterResourceOverride (selecting all clusters) to o
croName := fmt.Sprintf(croNameTemplate, GinkgoParallelProcess())

BeforeAll(func() {
Skip("CRO controller is not enabled yet")

By("creating work resources")
createWorkResources()

Expand Down
2 changes: 2 additions & 0 deletions test/e2e/placement_ro_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,8 @@ var _ = Describe("creating resourceOverride (selecting all clusters) to override
roNamespace := fmt.Sprintf(workNamespaceNameTemplate, GinkgoParallelProcess())

BeforeAll(func() {
Skip("RO controller is not enabled yet")

By("creating work resources")
createWorkResources()

Expand Down

0 comments on commit a17837e

Please sign in to comment.