mirror of https://github.com/k3s-io/k3s
Add more logging to diagnose flake
parent
06996d5af9
commit
d2f829edcc
|
@ -293,7 +293,7 @@ func podsOnNodes(c *client.Client, podNamespace string, labelSelector labels.Sel
|
|||
}
|
||||
for i := range pods.Items {
|
||||
pod := pods.Items[i]
|
||||
podString := fmt.Sprintf("%q/%q", pod.Namespace, pod.Name)
|
||||
podString := fmt.Sprintf("%s/%s", pod.Namespace, pod.Name)
|
||||
glog.Infof("Check whether pod %q exists on node %q", podString, pod.Spec.NodeName)
|
||||
if len(pod.Spec.NodeName) == 0 {
|
||||
glog.Infof("Pod %q is not bound to a host yet", podString)
|
||||
|
@ -354,6 +354,7 @@ func podRunning(c *client.Client, podNamespace string, podName string) wait.Cond
|
|||
return func() (bool, error) {
|
||||
pod, err := c.Pods(podNamespace).Get(podName)
|
||||
if apierrors.IsNotFound(err) {
|
||||
glog.V(2).Infof("Pod %s/%s was not found", podNamespace, podName)
|
||||
return false, nil
|
||||
}
|
||||
if err != nil {
|
||||
|
@ -362,6 +363,7 @@ func podRunning(c *client.Client, podNamespace string, podName string) wait.Cond
|
|||
return false, nil
|
||||
}
|
||||
if pod.Status.Phase != api.PodRunning {
|
||||
glog.V(2).Infof("Pod %s/%s is not running. In phase %q", podNamespace, podName, pod.Status.Phase)
|
||||
return false, nil
|
||||
}
|
||||
return true, nil
|
||||
|
|
Loading…
Reference in New Issue