mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-25 20:53:33 +00:00
check that innocent pod survives after evictions
This commit is contained in:
parent
17375fc59f
commit
b798df8c44
@ -233,7 +233,7 @@ func runEvictionTest(f *framework.Framework, testCondition string, podTestSpecs
|
|||||||
return nil
|
return nil
|
||||||
}, evictionTestTimeout, evictionPollInterval).Should(BeNil())
|
}, evictionTestTimeout, evictionPollInterval).Should(BeNil())
|
||||||
|
|
||||||
By("making sure conditions do not return")
|
By("making sure conditions do not return, and that pods that shouldnt fail dont fail")
|
||||||
Consistently(func() error {
|
Consistently(func() error {
|
||||||
hasPressure, err := hasPressureCondition(f, testCondition)
|
hasPressure, err := hasPressureCondition(f, testCondition)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@ -245,6 +245,18 @@ func runEvictionTest(f *framework.Framework, testCondition string, podTestSpecs
|
|||||||
if hasPressure {
|
if hasPressure {
|
||||||
return fmt.Errorf("%s dissappeared and then reappeared", testCondition)
|
return fmt.Errorf("%s dissappeared and then reappeared", testCondition)
|
||||||
}
|
}
|
||||||
|
// Gather current information
|
||||||
|
updatedPodList, _ := f.ClientSet.Core().Pods(f.Namespace.Name).List(metav1.ListOptions{})
|
||||||
|
for _, priorityPodSpec := range podTestSpecs {
|
||||||
|
// EvictionPriority 0 pods should not fail
|
||||||
|
if priorityPodSpec.evictionPriority == 0 {
|
||||||
|
for _, p := range updatedPodList.Items {
|
||||||
|
if p.Name == priorityPodSpec.pod.Name && p.Status.Phase == v1.PodFailed {
|
||||||
|
return fmt.Errorf("%s pod failed (delayed) and shouldn't have failed", p.Name)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
return nil
|
return nil
|
||||||
}, postTestConditionMonitoringPeriod, evictionPollInterval).Should(BeNil())
|
}, postTestConditionMonitoringPeriod, evictionPollInterval).Should(BeNil())
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user