@@ -576,18 +576,34 @@ var _ = SIGDescribe("Garbage collector", func() {
576
576
}
577
577
// wait for deployment to create some rs
578
578
ginkgo .By ("Wait for the Deployment to create new ReplicaSet" )
579
+ var replicaset appsv1.ReplicaSet
579
580
err = wait .PollImmediate (500 * time .Millisecond , 1 * time .Minute , func () (bool , error ) {
580
581
rsList , err := rsClient .List (context .TODO (), metav1.ListOptions {})
581
582
if err != nil {
582
583
return false , fmt .Errorf ("failed to list rs: %v" , err )
583
584
}
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
585
590
586
591
})
587
592
if err != nil {
588
593
framework .Failf ("Failed to wait for the Deployment to create some ReplicaSet: %v" , err )
589
594
}
590
595
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
+
591
607
ginkgo .By ("delete the deployment" )
592
608
deleteOptions := getOrphanOptions ()
593
609
deleteOptions .Preconditions = metav1 .NewUIDPreconditions (string (createdDeployment .UID ))
0 commit comments