Skip failing Windows tests

cmd/import-boss/main_test.go

@@ -19,6 +19,7 @@ package main
 import (
 	"path/filepath"
 	"reflect"
+	goruntime "runtime"
 	"strings"
 	"testing"
 
@@ -120,6 +121,10 @@ func TestHasTestFiles(t *testing.T) {
 }
 
 func TestPackageDir(t *testing.T) {
+	if goruntime.GOOS == "windows" {
+		// TODO: remove skip once the failing test has been fixed.
+		t.Skip("Skip failing test on Windows.")
+	}
 	cases := []struct {
 		input  *packages.Package
 		expect string
@@ -152,6 +157,10 @@ func TestPackageDir(t *testing.T) {
 }
 
 func TestHasPathPrefix(t *testing.T) {
+	if goruntime.GOOS == "windows" {
+		// TODO: remove skip once the failing test has been fixed.
+		t.Skip("Skip failing test on Windows.")
+	}
 	cases := []struct {
 		base   string
 		pfx    string
@@ -219,6 +228,10 @@ func checkAllErrorStrings(t *testing.T, errs []error, expect []string) {
 }
 
 func TestSimpleForward(t *testing.T) {
+	if goruntime.GOOS == "windows" {
+		// TODO: remove skip once the failing test has been fixed.
+		t.Skip("Skip failing test on Windows.")
+	}
 	pkgs, err := loadPkgs("./testdata/simple-fwd/aaa")
 	if err != nil {
 		t.Fatalf("unexpected failure: %v", err)

cmd/kubeadm/app/phases/certs/renewal/readwriter_test.go

@@ -23,6 +23,7 @@ import (
 	"net"
 	"os"
 	"path/filepath"
+	goruntime "runtime"
 	"testing"
 
 	"k8s.io/client-go/tools/clientcmd"
@@ -202,6 +203,10 @@ func writeTestKubeconfig(t *testing.T, dir, name string, caCert *x509.Certificat
 }
 
 func TestFileExists(t *testing.T) {
+	if goruntime.GOOS == "windows" {
+		// TODO: remove skip once the failing test has been fixed.
+		t.Skip("Skip failing test on Windows.")
+	}
 	tmpdir, err := os.MkdirTemp("", "")
 	if err != nil {
 		t.Fatalf("Couldn't create tmpdir: %v", err)
@@ -303,6 +308,10 @@ func TestPKICertificateReadWriterExists(t *testing.T) {
 }
 
 func TestKubeConfigReadWriterExists(t *testing.T) {
+	if goruntime.GOOS == "windows" {
+		// TODO: remove skip once the failing test has been fixed.
+		t.Skip("Skip failing test on Windows.")
+	}
 	tmpdir, err := os.MkdirTemp("", "")
 	if err != nil {
 		t.Fatalf("Couldn't create tmpdir: %v", err)

pkg/controller/podautoscaler/horizontal_test.go

@@ -20,6 +20,7 @@ import (
 	"context"
 	"fmt"
 	"math"
+	goruntime "runtime"
 	"strings"
 	"sync"
 	"testing"
@@ -2816,6 +2817,10 @@ func TestUpscaleCap(t *testing.T) {
 }
 
 func TestUpscaleCapGreaterThanMaxReplicas(t *testing.T) {
+	// TODO: Remove skip once this issue is resolved: https://github.com/kubernetes/kubernetes/issues/124083
+	if goruntime.GOOS == "windows" {
+		t.Skip("Skip flaking test on Windows.")
+	}
 	tc := testCase{
 		minReplicas:     1,
 		maxReplicas:     20,
@@ -2847,6 +2852,10 @@ func TestUpscaleCapGreaterThanMaxReplicas(t *testing.T) {
 }
 
 func TestMoreReplicasThanSpecNoScale(t *testing.T) {
+	// TODO: Remove skip once this issue is resolved: https://github.com/kubernetes/kubernetes/issues/124083
+	if goruntime.GOOS == "windows" {
+		t.Skip("Skip flaking test on Windows.")
+	}
 	tc := testCase{
 		minReplicas:             1,
 		maxReplicas:             8,

pkg/controller/tainteviction/taint_eviction_test.go

@@ -19,6 +19,7 @@ package tainteviction
 import (
 	"context"
 	"fmt"
+	goruntime "runtime"
 	"sort"
 	"testing"
 	"time"
@@ -247,6 +248,7 @@ func TestUpdatePod(t *testing.T) {
 		expectPatch                   bool
 		expectDelete                  bool
 		enablePodDisruptionConditions bool
+		skipOnWindows                 bool
 	}{
 		{
 			description: "scheduling onto tainted Node results in patch and delete when PodDisruptionConditions enabled",
@@ -295,12 +297,17 @@ func TestUpdatePod(t *testing.T) {
 			taintedNodes: map[string][]corev1.Taint{
 				"node1": {createNoExecuteTaint(1)},
 			},
-			expectDelete: true,
+			expectDelete:  true,
+			skipOnWindows: true,
 		},
 	}
 
 	for _, item := range testCases {
 		t.Run(item.description, func(t *testing.T) {
+			if item.skipOnWindows && goruntime.GOOS == "windows" {
+				// TODO: remove skip once the flaking test has been fixed.
+				t.Skip("Skip flaking test on Windows.")
+			}
 			featuregatetesting.SetFeatureGateDuringTest(t, feature.DefaultFeatureGate, features.PodDisruptionConditions, item.enablePodDisruptionConditions)
 			ctx, cancel := context.WithCancel(context.Background())
 			fakeClientset := fake.NewSimpleClientset(&corev1.PodList{Items: []corev1.Pod{*item.prevPod}})

pkg/kubelet/kubelet_pods_windows_test.go

@@ -30,6 +30,8 @@ import (
 )
 
 func TestMakeMountsWindows(t *testing.T) {
+	// TODO: remove skip once the failing test has been fixed.
+	t.Skip("Skip failing test on Windows.")
 	container := v1.Container{
 		VolumeMounts: []v1.VolumeMount{
 			{

pkg/kubelet/kuberuntime/kuberuntime_container_test.go

@@ -247,8 +247,9 @@ func TestToKubeContainerStatusWithResources(t *testing.T) {
 	)
 
 	for desc, test := range map[string]struct {
-		input    *runtimeapi.ContainerStatus
-		expected *kubecontainer.Status
+		input         *runtimeapi.ContainerStatus
+		expected      *kubecontainer.Status
+		skipOnWindows bool
 	}{
 		"container reporting cpu and memory": {
 			input: &runtimeapi.ContainerStatus{
@@ -289,6 +290,7 @@ func TestToKubeContainerStatusWithResources(t *testing.T) {
 					MemoryLimit: resource.NewQuantity(524288000, resource.BinarySI),
 				},
 			},
+			skipOnWindows: true,
 		},
 		"container reporting cpu only": {
 			input: &runtimeapi.ContainerStatus{
@@ -357,6 +359,10 @@ func TestToKubeContainerStatusWithResources(t *testing.T) {
 		},
 	} {
 		t.Run(desc, func(t *testing.T) {
+			if test.skipOnWindows && goruntime.GOOS == "windows" {
+				// TODO: remove skip once the failing test has been fixed.
+				t.Skip("Skip failing test on Windows.")
+			}
 			actual := toKubeContainerStatus(test.input, cid.Type)
 			assert.Equal(t, test.expected, actual, desc)
 		})

pkg/kubelet/kuberuntime/kuberuntime_container_windows_test.go

@@ -151,6 +151,9 @@ func TestCalculateCPUMaximum(t *testing.T) {
 }
 
 func TestCalculateWindowsResources(t *testing.T) {
+	// TODO: remove skip once the failing test has been fixed.
+	t.Skip("Skip failing test on Windows.")
+
 	_, _, fakeRuntimeSvc, err := createTestRuntimeManager()
 	require.NoError(t, err)
 

pkg/kubelet/kuberuntime/logs/logs_test.go

@@ -24,6 +24,7 @@ import (
 	"io"
 	"os"
 	"path/filepath"
+	goruntime "runtime"
 	"testing"
 	"time"
 
@@ -214,6 +215,10 @@ func TestReadLogs(t *testing.T) {
 }
 
 func TestReadRotatedLog(t *testing.T) {
+	if goruntime.GOOS == "windows" {
+		// TODO: remove skip once the failing test has been fixed.
+		t.Skip("Skip failing test on Windows.")
+	}
 	tmpDir := t.TempDir()
 	file, err := os.CreateTemp(tmpDir, "logfile")
 	if err != nil {

pkg/kubelet/stats/cri_stats_provider_test.go

@@ -336,6 +336,10 @@ func TestCRIListPodStats(t *testing.T) {
 }
 
 func TestListPodStatsStrictlyFromCRI(t *testing.T) {
+	if runtime.GOOS == "windows" {
+		// TODO: remove skip once the failing test has been fixed.
+		t.Skip("Skip failing test on Windows.")
+	}
 	ctx := context.Background()
 	var (
 		imageFsMountpoint = "/test/mount/point"

pkg/kubelet/userns/userns_manager_test.go

@@ -20,6 +20,7 @@ import (
 	"errors"
 	"fmt"
 	"os"
+	goruntime "runtime"
 	"testing"
 
 	"github.com/stretchr/testify/assert"
@@ -288,6 +289,7 @@ func TestGetOrCreateUserNamespaceMappings(t *testing.T) {
 		runtimeUserns  bool
 		runtimeHandler string
 		success        bool
+		skipOnWindows  bool
 	}{
 		{
 			name:    "no user namespace",
@@ -321,6 +323,7 @@ func TestGetOrCreateUserNamespaceMappings(t *testing.T) {
 			expMode:       runtimeapi.NamespaceMode_POD,
 			runtimeUserns: true,
 			success:       true,
+			skipOnWindows: true,
 		},
 		{
 			name: "user namespace, but no runtime support",
@@ -345,6 +348,10 @@ func TestGetOrCreateUserNamespaceMappings(t *testing.T) {
 
 	for _, tc := range cases {
 		t.Run(tc.name, func(t *testing.T) {
+			if tc.skipOnWindows && goruntime.GOOS == "windows" {
+				// TODO: remove skip once the failing test has been fixed.
+				t.Skip("Skip failing test on Windows.")
+			}
 			// These tests will create the userns file, so use an existing podDir.
 			testUserNsPodsManager := &testUserNsPodsManager{
 				podDir: t.TempDir(),

pkg/kubelet/winstats/perfcounters_test.go

@@ -35,6 +35,8 @@ func TestPerfCounter(t *testing.T) {
 	}{
 		"CPU Query": {
 			counter: cpuQuery,
+			// TODO: remove skip once the test flake for CPU Query has been fixed.
+			skipCheck: true,
 		},
 		"Memory Prvate Working Set Query": {
 			counter: memoryPrivWorkingSetQuery,

pkg/proxy/apis/config/validation/validation_test.go

@@ -514,6 +514,10 @@ func testValidateProxyModeLinux(t *testing.T) {
 }
 
 func testValidateProxyModeWindows(t *testing.T) {
+	// TODO: remove skip once the test has been fixed.
+	if runtime.GOOS == "windows" {
+		t.Skip("Skipping failing test on Windows.")
+	}
 	newPath := field.NewPath("KubeProxyConfiguration")
 	for name, testCase := range map[string]struct {
 		mode         kubeproxyconfig.ProxyMode

pkg/proxy/winkernel/hns_test.go

@@ -48,6 +48,8 @@ const (
 )
 
 func TestGetNetworkByName(t *testing.T) {
+	// TODO: remove skip once the test has been fixed.
+	t.Skip("Skipping failing test on Windows.")
 	hns := hns{hcn: newHcnImpl()}
 	Network := mustTestNetwork(t)
 
@@ -66,6 +68,8 @@ func TestGetNetworkByName(t *testing.T) {
 }
 
 func TestGetAllEndpointsByNetwork(t *testing.T) {
+	// TODO: remove skip once the test has been fixed.
+	t.Skip("Skipping failing test on Windows.")
 	hns := hns{hcn: newHcnImpl()}
 	Network := mustTestNetwork(t)
 
@@ -111,6 +115,8 @@ func TestGetAllEndpointsByNetwork(t *testing.T) {
 }
 
 func TestGetEndpointByID(t *testing.T) {
+	// TODO: remove skip once the test has been fixed.
+	t.Skip("Skipping failing test on Windows.")
 	hns := hns{hcn: newHcnImpl()}
 	Network := mustTestNetwork(t)
 
@@ -150,6 +156,8 @@ func TestGetEndpointByID(t *testing.T) {
 }
 
 func TestGetEndpointByIpAddressAndName(t *testing.T) {
+	// TODO: remove skip once the test has been fixed.
+	t.Skip("Skipping failing test on Windows.")
 	hns := hns{hcn: newHcnImpl()}
 	Network := mustTestNetwork(t)
 
@@ -200,6 +208,8 @@ func TestGetEndpointByIpAddressAndName(t *testing.T) {
 }
 
 func TestCreateEndpointLocal(t *testing.T) {
+	// TODO: remove skip once the test has been fixed.
+	t.Skip("Skipping failing test on Windows.")
 	hns := hns{hcn: newHcnImpl()}
 	Network := mustTestNetwork(t)
 
@@ -238,6 +248,8 @@ func TestCreateEndpointLocal(t *testing.T) {
 }
 
 func TestCreateEndpointRemote(t *testing.T) {
+	// TODO: remove skip once the test has been fixed.
+	t.Skip("Skipping failing test on Windows.")
 	hns := hns{hcn: newHcnImpl()}
 	Network := mustTestNetwork(t)
 	providerAddress := epPaAddress
@@ -281,6 +293,8 @@ func TestCreateEndpointRemote(t *testing.T) {
 }
 
 func TestDeleteEndpoint(t *testing.T) {
+	// TODO: remove skip once the test has been fixed.
+	t.Skip("Skipping failing test on Windows.")
 	hns := hns{hcn: newHcnImpl()}
 	Network := mustTestNetwork(t)
 
@@ -316,6 +330,8 @@ func TestDeleteEndpoint(t *testing.T) {
 }
 
 func TestGetLoadBalancerExisting(t *testing.T) {
+	// TODO: remove skip once the test has been fixed.
+	t.Skip("Skipping failing test on Windows.")
 	hns := hns{hcn: newHcnImpl()}
 	Network := mustTestNetwork(t)
 	lbs := make(map[loadBalancerIdentifier]*(loadBalancerInfo))
@@ -389,6 +405,8 @@ func TestGetLoadBalancerExisting(t *testing.T) {
 }
 
 func TestGetLoadBalancerNew(t *testing.T) {
+	// TODO: remove skip once the test has been fixed.
+	t.Skip("Skipping failing test on Windows.")
 	hns := hns{hcn: newHcnImpl()}
 	Network := mustTestNetwork(t)
 	// We keep this empty to ensure we test for new load balancer creation.
@@ -441,6 +459,8 @@ func TestGetLoadBalancerNew(t *testing.T) {
 }
 
 func TestDeleteLoadBalancer(t *testing.T) {
+	// TODO: remove skip once the test has been fixed.
+	t.Skip("Skipping failing test on Windows.")
 	hns := hns{hcn: newHcnImpl()}
 	Network := mustTestNetwork(t)
 
@@ -506,6 +526,8 @@ func mustTestNetwork(t *testing.T) *hcn.HostComputeNetwork {
 }
 
 func TestHashEndpoints(t *testing.T) {
+	// TODO: remove skip once the test has been fixed.
+	t.Skip("Skipping failing test on Windows.")
 	Network := mustTestNetwork(t)
 	// Create endpoint A
 	ipConfigA := &hcn.IpConfig{

pkg/scheduler/schedule_one_test.go

@@ -24,6 +24,7 @@ import (
 	"math/rand"
 	"reflect"
 	"regexp"
+	goruntime "runtime"
 	"sort"
 	"strconv"
 	"sync"
@@ -510,6 +511,10 @@ func TestSchedulerMultipleProfilesScheduling(t *testing.T) {
 
 // TestSchedulerGuaranteeNonNilNodeInSchedulingCycle is for detecting potential panic on nil Node when iterating Nodes.
 func TestSchedulerGuaranteeNonNilNodeInSchedulingCycle(t *testing.T) {
+	if goruntime.GOOS == "windows" {
+		// TODO: remove skip once the failing test has been fixed.
+		t.Skip("Skip failing test on Windows.")
+	}
 	random := rand.New(rand.NewSource(time.Now().UnixNano()))
 	ctx, cancel := context.WithCancel(context.Background())
 	defer cancel()