Skip to content
This repository was archived by the owner on Jun 29, 2022. It is now read-only.

Commit b1f03f0

Browse files
committed
test/components/kubernetes: remove kubelet pod when testing node labels
Re-starting the pod will immidiately trigger re-adding the node, which should make test less flaky. Closes #1036 Signed-off-by: Mateusz Gozdek <mateusz@kinvolk.io>
1 parent c01551a commit b1f03f0

File tree

1 file changed

+20
-0
lines changed

1 file changed

+20
-0
lines changed

test/components/kubernetes/kubelet_disruptive_test.go

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,26 @@ func TestSelfHostedKubeletLabels(t *testing.T) {
4949
t.Errorf("could not delete the node %s: %v", chosenNode, err)
5050
}
5151

52+
pc := client.CoreV1().Pods("kube-system")
53+
54+
pods, err := pc.List(context.TODO(), metav1.ListOptions{
55+
LabelSelector: "k8s-app=kubelet",
56+
FieldSelector: "spec.nodeName=" + chosenNode,
57+
})
58+
if err != nil {
59+
t.Fatalf("Getting kubelet pods on node %q: %v", chosenNode, err)
60+
}
61+
62+
if len(pods.Items) != 1 {
63+
t.Fatalf("Found %d kubelet pods on node %q, expected 1", len(pods.Items), chosenNode)
64+
}
65+
66+
pod := pods.Items[0]
67+
68+
if err := pc.Delete(context.TODO(), pod.Name, metav1.DeleteOptions{}); err != nil {
69+
t.Fatalf("Deleting kubelet pod %q on node %q: %v", chosenNode, pod.Name, err)
70+
}
71+
5272
retryInterval := time.Second * 5
5373
timeout := time.Minute * 5
5474
// Wait for the node to come up.

0 commit comments

Comments
 (0)