Skip to content

Commit 1949761

Browse files
committed
Extend e2e test
1 parent f2a6db0 commit 1949761

1 file changed

Lines changed: 26 additions & 0 deletions

File tree

slice/test/e2e/jobset_test.go

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1567,6 +1567,32 @@ var _ = ginkgo.Describe("JobSet", func() {
15671567
sliceHealthyUID := sliceHealthy.UID
15681568
sliceTolerantUID := sliceTolerant.UID
15691569

1570+
ginkgo.By("Setting both Slices to ACTIVE", func() {
1571+
for _, s := range []*slice.Slice{sliceHealthy, sliceTolerant} {
1572+
gomega.Eventually(func(g gomega.Gomega) {
1573+
g.Expect(k8sClient.Get(ctx, client.ObjectKeyFromObject(s), s)).To(gomega.Succeed())
1574+
meta.SetStatusCondition(&s.Status.Conditions, metav1.Condition{
1575+
Type: slice.SliceStateConditionType,
1576+
Status: metav1.ConditionTrue,
1577+
Reason: string(core.MMIGHealthStatusActive),
1578+
Message: "Active by test",
1579+
})
1580+
g.Expect(k8sClient.Status().Update(ctx, s)).To(gomega.Succeed())
1581+
}, utils.Timeout, utils.Interval).Should(gomega.Succeed())
1582+
}
1583+
})
1584+
1585+
ginkgo.By("Checking that the Workload Admission Check state is Ready", func() {
1586+
gomega.Eventually(func(g gomega.Gomega) {
1587+
g.Expect(k8sClient.Get(ctx, wlKey, createdWorkload)).Should(gomega.Succeed())
1588+
g.Expect(createdWorkload.Status.AdmissionChecks).Should(gomega.BeComparableTo([]kueue.AdmissionCheckState{{
1589+
Name: kueue.AdmissionCheckReference(ac.Name),
1590+
State: kueue.CheckStateReady,
1591+
Message: `Slices are in states: 2 ACTIVE`,
1592+
}}, cmpopts.IgnoreFields(kueue.AdmissionCheckState{}, "LastTransitionTime", "PodSetUpdates", "RequeueAfterSeconds")))
1593+
}, utils.LongTimeout, utils.Interval).Should(gomega.Succeed())
1594+
})
1595+
15701596
ginkgo.By("Setting both Slices to DEGRADED", func() {
15711597
for _, s := range []*slice.Slice{sliceHealthy, sliceTolerant} {
15721598
gomega.Eventually(func(g gomega.Gomega) {

0 commit comments

Comments
 (0)