github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2026-07-18 04:54:54 +00:00
Code Issues Projects Releases Wiki Activity

DRA: Fix flaky integration test

Browse Source
This commit is contained in:
Morten Torkildsen
2025-11-25 18:13:00 +00:00
parent 5bcb759973
commit c33c0464db
1 changed files with 15 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
test/integration/dra/dra_test.go
View File

@@ -783,12 +783,25 @@ func expectedAllocatedClaim(request string, nodeInfo nodeInfo) gtypes.GomegaMatc
func testExtendedResource(tCtx ktesting.TContext, enabled bool) {
tCtx.Parallel()
c, err := tCtx.Client().ResourceV1().DeviceClasses().Create(tCtx, classWithExtendedResource, metav1.CreateOptions{FieldValidation: "Strict"})
namespace := createTestNamespace(tCtx, nil)
driverName := namespace + driverNameSuffix
class := classWithExtendedResource.DeepCopy()
class.Spec.Selectors = []resourceapi.DeviceSelector{{
CEL: &resourceapi.CELDeviceSelector{
Expression: fmt.Sprintf("device.driver == %q", driverName),
},
}}
c, err := tCtx.Client().ResourceV1().DeviceClasses().Create(tCtx, class, metav1.CreateOptions{FieldValidation: "Strict"})
tCtx.ExpectNoError(err, "create class")
slice := st.MakeResourceSlice("worker-0", driverName).Devices(device1)
createSlice(tCtx, slice.Obj())
if enabled {
require.NotEmpty(tCtx, c.Spec.ExtendedResourceName, "should store ExtendedResourceName")
}
namespace := createTestNamespace(tCtx, nil)
tCtx.Run("scheduler", func(tCtx ktesting.TContext) {
startScheduler(tCtx)