@@ -44,7 +44,6 @@ import (
44
44
"k8s.io/kubernetes/pkg/features"
45
45
"k8s.io/kubernetes/pkg/scheduler/framework"
46
46
"k8s.io/kubernetes/pkg/scheduler/framework/plugins/queuesort"
47
- "k8s.io/kubernetes/pkg/scheduler/framework/plugins/schedulinggates"
48
47
"k8s.io/kubernetes/pkg/scheduler/metrics"
49
48
st "k8s.io/kubernetes/pkg/scheduler/testing"
50
49
"k8s.io/kubernetes/pkg/scheduler/util"
@@ -3743,30 +3742,3 @@ func Test_isPodWorthRequeuing(t *testing.T) {
3743
3742
})
3744
3743
}
3745
3744
}
3746
-
3747
- func Test_queuedPodInfo_gatedSetUponCreationAndUnsetUponUpdate (t * testing.T ) {
3748
- logger , ctx := ktesting .NewTestContext (t )
3749
- plugin , _ := schedulinggates .New (ctx , nil , nil )
3750
- m := map [string ][]framework.PreEnqueuePlugin {"" : {plugin .(framework.PreEnqueuePlugin )}}
3751
- q := NewTestQueue (ctx , newDefaultQueueSort (), WithPreEnqueuePluginMap (m ))
3752
-
3753
- gatedPod := st .MakePod ().SchedulingGates ([]string {"hello world" }).Obj ()
3754
- if err := q .Add (logger , gatedPod ); err != nil {
3755
- t .Error ("Error calling Add" )
3756
- }
3757
-
3758
- if ! q .unschedulablePods .get (gatedPod ).Gated {
3759
- t .Error ("expected pod to be gated" )
3760
- }
3761
-
3762
- ungatedPod := gatedPod .DeepCopy ()
3763
- ungatedPod .Spec .SchedulingGates = nil
3764
- if err := q .Update (logger , gatedPod , ungatedPod ); err != nil {
3765
- t .Error ("Error calling Update" )
3766
- }
3767
-
3768
- ungatedPodInfo , _ := q .Pop (logger )
3769
- if ungatedPodInfo .Gated {
3770
- t .Error ("expected pod to be ungated" )
3771
- }
3772
- }
0 commit comments