Skip to content

Commit 84b5213

Browse files
authored
test: fix drain E2E flakiness (#49)
1 parent 671b313 commit 84b5213

File tree

1 file changed

+20
-0
lines changed

1 file changed

+20
-0
lines changed

test/e2e/drain_tool_test.go

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -276,6 +276,26 @@ var _ = Describe("Drain is allowed on one cluster, blocked on others - ClusterRe
276276
}
277277
})
278278

279+
It("should ensure no resources exist on drained clusters", func() {
280+
for _, cluster := range drainClusters {
281+
resourceRemovedActual := workNamespaceRemovedFromClusterActual(cluster)
282+
Eventually(resourceRemovedActual, eventuallyDuration, eventuallyInterval).Should(Succeed(), "Failed to check if resources doesn't exist on member cluster")
283+
}
284+
})
285+
286+
It("should update cluster resource placement status as expected", func() {
287+
crpStatusUpdatedActual := crpStatusUpdatedActual(workResourceIdentifiers(), noDrainClusterNames, nil, "0")
288+
Eventually(crpStatusUpdatedActual, eventuallyDuration, eventuallyInterval).Should(Succeed(), "Failed to update cluster resource placement status as expected")
289+
Consistently(crpStatusUpdatedActual, consistentlyDuration, consistentlyInterval).Should(Succeed(), "Failed to update cluster resource placement status as expected")
290+
})
291+
292+
It("should still place resources on the selected clusters which were not drained", func() {
293+
for _, cluster := range noDrainClusters {
294+
resourcePlacedActual := workNamespaceAndConfigMapPlacedOnClusterActual(cluster)
295+
Eventually(resourcePlacedActual, eventuallyDuration, eventuallyInterval).Should(Succeed(), "Failed to place resources on the selected clusters")
296+
}
297+
})
298+
279299
It("remove drain evictions for member cluster 1", func() {
280300
for _, eviction := range drainEvictions {
281301
ensureCRPEvictionDeleted(eviction.Name)

0 commit comments

Comments
 (0)