fix(test): add parallel statement for qrm tests

kubewharf · May 6, 2024 · 2c36e29 · 2c36e29
1 parent 17410b8
commit 2c36e29
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/pkg/agent/qrm-plugins/cpu/dynamicpolicy/state/state_test.go b/pkg/agent/qrm-plugins/cpu/dynamicpolicy/state/state_test.go
@@ -2544,6 +2544,7 @@ func TestGetSocketTopology(t *testing.T) {
 	}
 }
 func TestAllocationInfo_GetSpecifiedNUMABindingPoolName(t *testing.T) {
+	t.Parallel()
 	testName := "test"
 
 	type fields struct {
@@ -2706,6 +2707,7 @@ func TestAllocationInfo_GetSpecifiedNUMABindingPoolName(t *testing.T) {
 	}
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
+			t.Parallel()
 			ai := &AllocationInfo{
 				PodUid:                           tt.fields.PodUid,
 				PodNamespace:                     tt.fields.PodNamespace,
@@ -2740,6 +2742,7 @@ func TestAllocationInfo_GetSpecifiedNUMABindingPoolName(t *testing.T) {
 }
 
 func TestCheckNUMABindingSharedCoresAntiAffinity(t *testing.T) {
+	t.Parallel()
 	testName := "test"
 	type args struct {
 		ai          *AllocationInfo
@@ -2868,6 +2871,7 @@ func TestCheckNUMABindingSharedCoresAntiAffinity(t *testing.T) {
 	}
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
+			t.Parallel()
 			if got := CheckNUMABindingSharedCoresAntiAffinity(tt.args.ai, tt.args.annotations); got != tt.want {
 				t.Errorf("CheckNUMABindingSharedCoresAntiAffinity() = %v, want %v", got, tt.want)
 			}
@@ -2876,6 +2880,7 @@ func TestCheckNUMABindingSharedCoresAntiAffinity(t *testing.T) {
 }
 
 func TestPodEntries_GetFilteredPoolsCPUSetMap(t *testing.T) {
+	t.Parallel()
 	testName := "test"
 	type args struct {
 		ignorePools sets.String
@@ -3090,6 +3095,7 @@ func TestPodEntries_GetFilteredPoolsCPUSetMap(t *testing.T) {
 	}
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
+			t.Parallel()
 			got, err := tt.pe.GetFilteredPoolsCPUSetMap(tt.args.ignorePools)
 			if (err != nil) != tt.wantErr {
 				t.Errorf("PodEntries.GetFilteredPoolsCPUSetMap() error = %v, wantErr %v", err, tt.wantErr)

diff --git a/pkg/agent/qrm-plugins/cpu/dynamicpolicy/state/util_test.go b/pkg/agent/qrm-plugins/cpu/dynamicpolicy/state/util_test.go
@@ -566,6 +566,7 @@ func TestGetSpecifiedPoolName(t *testing.T) {
 }
 
 func TestCountAllocationInfosToPoolsQuantityMap(t *testing.T) {
+	t.Parallel()
 	testName := "test"
 	SetContainerRequestedCores(func(allocationInfo *AllocationInfo) float64 {
 		return allocationInfo.RequestQuantity
@@ -849,6 +850,7 @@ func TestCountAllocationInfosToPoolsQuantityMap(t *testing.T) {
 	}
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
+			t.Parallel()
 			if err := CountAllocationInfosToPoolsQuantityMap(tt.args.allocationInfos, tt.args.poolsQuantityMap); (err != nil) != tt.wantErr {
 				t.Errorf("CountAllocationInfosToPoolsQuantityMap() error = %v, wantErr %v", err, tt.wantErr)
 			} else if err == nil {