Ensure DeleteDeployment waits until there are no pods running (#5269)
This commit is contained in:
parent
78bd7d1642
commit
d72ff0f8af
1 changed files with 7 additions and 2 deletions
|
@ -368,9 +368,14 @@ func (f *Framework) NewDeployment(name, image string, port int32, replicas int32
|
||||||
func (f *Framework) DeleteDeployment(name string) error {
|
func (f *Framework) DeleteDeployment(name string) error {
|
||||||
d, err := f.KubeClientSet.AppsV1().Deployments(f.Namespace).Get(name, metav1.GetOptions{})
|
d, err := f.KubeClientSet.AppsV1().Deployments(f.Namespace).Get(name, metav1.GetOptions{})
|
||||||
assert.Nil(ginkgo.GinkgoT(), err, "getting deployment")
|
assert.Nil(ginkgo.GinkgoT(), err, "getting deployment")
|
||||||
err = f.KubeClientSet.AppsV1().Deployments(f.Namespace).Delete(name, &metav1.DeleteOptions{})
|
|
||||||
|
grace := int64(0)
|
||||||
|
err = f.KubeClientSet.AppsV1().Deployments(f.Namespace).Delete(name, &metav1.DeleteOptions{
|
||||||
|
GracePeriodSeconds: &grace,
|
||||||
|
})
|
||||||
assert.Nil(ginkgo.GinkgoT(), err, "deleting deployment")
|
assert.Nil(ginkgo.GinkgoT(), err, "deleting deployment")
|
||||||
return WaitForPodsDeleted(f.KubeClientSet, time.Second*60, f.Namespace, metav1.ListOptions{
|
|
||||||
|
return WaitForPodsDeleted(f.KubeClientSet, 2*time.Minute, f.Namespace, metav1.ListOptions{
|
||||||
LabelSelector: labelSelectorToString(d.Spec.Selector.MatchLabels),
|
LabelSelector: labelSelectorToString(d.Spec.Selector.MatchLabels),
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue