From a652a4aa95dbe92159bb273a3b64ff8837d92660 Mon Sep 17 00:00:00 2001 From: Reed Schalo Date: Mon, 14 Oct 2024 10:58:22 -0700 Subject: [PATCH] chore: remove dead disruptable code (#1751) --- pkg/controllers/state/statenode.go | 15 --------------- 1 file changed, 15 deletions(-) diff --git a/pkg/controllers/state/statenode.go b/pkg/controllers/state/statenode.go index c8657e1690..e3d1e84276 100644 --- a/pkg/controllers/state/statenode.go +++ b/pkg/controllers/state/statenode.go @@ -28,7 +28,6 @@ import ( "k8s.io/apimachinery/pkg/api/equality" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types" - "k8s.io/utils/clock" "sigs.k8s.io/controller-runtime/pkg/client" v1 "sigs.k8s.io/karpenter/pkg/apis/v1" @@ -89,20 +88,6 @@ func (n StateNodes) Pods(ctx context.Context, kubeClient client.Client) ([]*core return pods, nil } -// Disruptable filters StateNodes that are meet the IsDisruptable condition -func (n StateNodes) Disruptable(ctx context.Context, clk clock.Clock, kubeClient client.Client) (StateNodes, error) { - pdbs, err := pdb.NewLimits(ctx, clk, kubeClient) - if err != nil { - return StateNodes{}, fmt.Errorf("constructing pdbs, %w", err) - } - n = lo.Filter(n, func(node *StateNode, _ int) bool { - nodeDisruptibleErr := node.ValidateNodeDisruptable(ctx, kubeClient) - _, podDisruptibleErr := node.ValidatePodsDisruptable(ctx, kubeClient, pdbs) - return nodeDisruptibleErr == nil && podDisruptibleErr == nil - }) - return n, nil -} - func (n StateNodes) ReschedulablePods(ctx context.Context, kubeClient client.Client) ([]*corev1.Pod, error) { var pods []*corev1.Pod for _, node := range n {