github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-16 23:29:21 +00:00
Code Issues Projects Releases Wiki Activity

Fix the e2e bug related to the Garbage collector in api-machinery.

Browse Source 
Signed-off-by: bzsuni <bingzhe.sun@daocloud.io>
This commit is contained in:
bzsuni 2023-10-28 17:35:54 +08:00
parent e0a623d191
commit b2c743154c
1 changed files with 5 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
test/e2e/apimachinery/garbage_collector.go
View File

@ -1101,14 +1101,11 @@ var _ = SIGDescribe("Garbage collector", func() {
framework.Failf("timeout in waiting for the owner to be deleted: %v", err)
}
// Wait 30s and ensure the dependent is not deleted.
ginkgo.By("wait for 30 seconds to see if the garbage collector mistakenly deletes the dependent crd")
if err := wait.PollWithContext(ctx, 5*time.Second, 30*time.Second+gcInformerResyncRetryTimeout, func(ctx context.Context) (bool, error) {
_, err := resourceClient.Get(ctx, dependentName, metav1.GetOptions{})
return false, err
}); err != nil && !wait.Interrupted(err) {
framework.Failf("failed to ensure the dependent is not deleted: %v", err)
}
timeout := 30*time.Second + gcInformerResyncRetryTimeout
ginkgo.By(fmt.Sprintf("wait for %s to see if the garbage collector mistakenly deletes the dependent crd\n", timeout))
gomega.Consistently(ctx, framework.HandleRetry(func(ctx context.Context) (*unstructured.Unstructured, error) {
return resourceClient.Get(ctx, dependentName, metav1.GetOptions{})
})).WithTimeout(timeout).WithPolling(5 * time.Second).ShouldNot(gomega.BeNil())
})
ginkgo.It("should delete jobs and pods created by cronjob", func(ctx context.Context) {