Skip to content

Commit

Permalink
Merge pull request #11101 from jcanocan/fix-eventually
Browse files Browse the repository at this point in the history
fix: `Eventually()` missing `Should()` statement and sync error
  • Loading branch information
kubevirt-bot committed Feb 3, 2024
2 parents 51da9c7 + e43402d commit 2dab5d4
Showing 1 changed file with 15 additions and 7 deletions.
22 changes: 15 additions & 7 deletions tests/vm_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -1958,24 +1958,32 @@ status:

Context("[Serial] when node becomes unhealthy", Serial, func() {
const componentName = "virt-handler"
var nodeName string

AfterEach(func() {
libpod.DeleteKubernetesApiBlackhole(getHandlerNodePod(virtClient, nodeName), componentName)
Eventually(func(g Gomega) {
g.Expect(getHandlerNodePod(virtClient, nodeName).Items[0]).To(HaveConditionTrue(k8sv1.PodReady))
}, 120*time.Second, time.Second).Should(Succeed())

tests.WaitForConfigToBePropagatedToComponent("kubevirt.io=virt-handler", util.GetCurrentKv(virtClient).ResourceVersion,
tests.ExpectResourceVersionToBeLessEqualThanConfigVersion, 120*time.Second)
})

It("[Serial] the VMs running in that node should be respawned", func() {
By("Starting VM")
vm := startVM(virtClient, createVM(virtClient, libvmi.NewCirros()))
vmi, err := virtClient.VirtualMachineInstance(vm.Namespace).Get(context.Background(), vm.Name, &k8smetav1.GetOptions{})
Expect(err).ToNot(HaveOccurred())

nodeName := vmi.Status.NodeName
nodeName = vmi.Status.NodeName
oldUID := vmi.UID

By("Blocking virt-handler from reconciling the VMI")
libpod.AddKubernetesApiBlackhole(getHandlerNodePod(virtClient, nodeName), componentName)
Eventually(getHandlerNodePod(virtClient, nodeName).Items[0], 120*time.Second, time.Second, HaveConditionFalse(k8sv1.PodReady))

DeferCleanup(func() {
libpod.DeleteKubernetesApiBlackhole(getHandlerNodePod(virtClient, nodeName), componentName)
Eventually(getHandlerNodePod(virtClient, nodeName).Items[0], 120*time.Second, time.Second, HaveConditionTrue(k8sv1.PodReady))
})
Eventually(func(g Gomega) {
g.Expect(getHandlerNodePod(virtClient, nodeName).Items[0]).To(HaveConditionFalse(k8sv1.PodReady))
}, 120*time.Second, time.Second).Should(Succeed())

pod, err := libvmi.GetPodByVirtualMachineInstance(vmi, vmi.Namespace)
Expect(err).ToNot(HaveOccurred())
Expand Down

0 comments on commit 2dab5d4

Please sign in to comment.