Skip to content

Commit 06e8780

Browse files
committed
conformance-tests: make orpan RS created by deployment test more resilient
1 parent dd649bb commit 06e8780

File tree

1 file changed

+17
-1
lines changed

1 file changed

+17
-1
lines changed

test/e2e/apimachinery/garbage_collector.go

Lines changed: 17 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -576,18 +576,34 @@ var _ = SIGDescribe("Garbage collector", func() {
576576
}
577577
// wait for deployment to create some rs
578578
ginkgo.By("Wait for the Deployment to create new ReplicaSet")
579+
var replicaset appsv1.ReplicaSet
579580
err = wait.PollImmediate(500*time.Millisecond, 1*time.Minute, func() (bool, error) {
580581
rsList, err := rsClient.List(context.TODO(), metav1.ListOptions{})
581582
if err != nil {
582583
return false, fmt.Errorf("failed to list rs: %v", err)
583584
}
584-
return len(rsList.Items) > 0, nil
585+
if len(rsList.Items) > 0 {
586+
replicaset = rsList.Items[0]
587+
return true, nil
588+
}
589+
return false, nil
585590

586591
})
587592
if err != nil {
588593
framework.Failf("Failed to wait for the Deployment to create some ReplicaSet: %v", err)
589594
}
590595

596+
desiredGeneration := replicaset.Generation
597+
if err := wait.PollImmediate(100*time.Millisecond, 60*time.Second, func() (bool, error) {
598+
newRS, err := clientSet.AppsV1().ReplicaSets(replicaset.Namespace).Get(context.TODO(), replicaset.Name, metav1.GetOptions{})
599+
if err != nil {
600+
return false, err
601+
}
602+
return newRS.Status.ObservedGeneration >= desiredGeneration && newRS.Status.Replicas == *replicaset.Spec.Replicas, nil
603+
}); err != nil {
604+
framework.Failf("failed to verify .Status.Replicas is equal to .Spec.Replicas for replicaset %q: %v", replicaset.Name, err)
605+
}
606+
591607
ginkgo.By("delete the deployment")
592608
deleteOptions := getOrphanOptions()
593609
deleteOptions.Preconditions = metav1.NewUIDPreconditions(string(createdDeployment.UID))

0 commit comments

Comments
 (0)