diff --git a/pkg/controller/controller.go b/pkg/controller/controller.go index 9ec7f487f..8b81a9ae6 100644 --- a/pkg/controller/controller.go +++ b/pkg/controller/controller.go @@ -51,7 +51,6 @@ func Initialize() { } if features.IsControllerEnabled(features.DistributedInferenceController) { - // TODO: only enable them if KubeRay is installed (check RayCluster CRD exist) controllerAddFuncs = append(controllerAddFuncs, rayclusterreplicaset.Add) controllerAddFuncs = append(controllerAddFuncs, rayclusterfleet.Add) } diff --git a/pkg/controller/rayclusterfleet/rayclusterfleet_controller.go b/pkg/controller/rayclusterfleet/rayclusterfleet_controller.go index 054056821..01aeab198 100644 --- a/pkg/controller/rayclusterfleet/rayclusterfleet_controller.go +++ b/pkg/controller/rayclusterfleet/rayclusterfleet_controller.go @@ -51,8 +51,6 @@ var ( // Add creates a new RayClusterFleet Controller and adds it to the Manager with default RBAC. // The Manager will set fields on the Controller and Start it when the Manager is Started. func Add(mgr manager.Manager, runtimeConfig config.RuntimeConfig) error { - // TODO: check crd exists or not. If not, we should fail here directly without moving forward. - r, err := newReconciler(mgr, runtimeConfig) if err != nil { return err