Skip to content

Commit d6fe21f

Browse files
authored
Fix should admit workload which fits in a required topology domain test. (#7983)
1 parent e3f650b commit d6fe21f

File tree

2 files changed

+5
-0
lines changed

2 files changed

+5
-0
lines changed

test/integration/singlecluster/controller/jobs/jobset/jobset_controller_test.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1191,6 +1191,7 @@ var _ = ginkgo.Describe("JobSet controller with TopologyAwareScheduling", ginkgo
11911191

11921192
localQueue = utiltestingapi.MakeLocalQueue("local-queue", ns.Name).ClusterQueue(clusterQueue.Name).Obj()
11931193
util.MustCreate(ctx, k8sClient, localQueue)
1194+
util.ExpectLocalQueuesToBeActive(ctx, k8sClient, localQueue)
11941195
})
11951196

11961197
ginkgo.AfterEach(func() {

test/integration/singlecluster/controller/jobs/jobset/suite_test.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@ import (
3131
schdcache "sigs.k8s.io/kueue/pkg/cache/scheduler"
3232
"sigs.k8s.io/kueue/pkg/constants"
3333
"sigs.k8s.io/kueue/pkg/controller/core"
34+
"sigs.k8s.io/kueue/pkg/controller/core/indexer"
3435
"sigs.k8s.io/kueue/pkg/controller/jobframework"
3536
"sigs.k8s.io/kueue/pkg/controller/jobs/jobset"
3637
"sigs.k8s.io/kueue/pkg/controller/tas"
@@ -101,6 +102,9 @@ func managerAndSchedulerSetup(setupTASControllers bool, opts ...jobframework.Opt
101102
failedCtrl, err := core.SetupControllers(mgr, queues, cCache, configuration)
102103
gomega.Expect(err).ToNot(gomega.HaveOccurred(), "controller", failedCtrl)
103104

105+
err = indexer.Setup(ctx, mgr.GetFieldIndexer())
106+
gomega.Expect(err).NotTo(gomega.HaveOccurred())
107+
104108
if setupTASControllers {
105109
failedCtrl, err = tas.SetupControllers(mgr, queues, cCache, configuration)
106110
gomega.Expect(err).ToNot(gomega.HaveOccurred(), "TAS controller", failedCtrl)

0 commit comments

Comments
 (0)