kubelet: Fallback to api server for pod status

This commit fixes getting the logs from complete/failed pods after a kubelet restart by falling back to the api server in case we fail to resolve the pod status using the status cache.

kubelet: Fallback to api server for pod status
d519741e · kargakis · 3a5768a0 · d519741e
Commit d519741e authored Nov 06, 2015 by kargakis
Hide whitespace changes
Inline Side-by-side

Showing with 4 additions and 1 deletion

kubelet.go pkg/kubelet/kubelet.go +4 -1

No files found.
--- a/pkg/kubelet/kubelet.go
+++ b/pkg/kubelet/kubelet.go
@@ -2311,7 +2311,10 @@ func (kl *Kubelet) GetKubeletContainerLogs(podFullName, containerName string, lo
 	}
 	podStatus, found := kl.statusManager.GetPodStatus(podUID)
 	if !found {
-		return fmt.Errorf("failed to get status for pod %q in namespace %q", name, namespace)
+		// If there is no cached status, use the status from the
+		// apiserver. This is useful if kubelet has recently been
+		// restarted.
+		podStatus = pod.Status
 	}

 	if err := kl.validatePodPhase(&podStatus); err != nil {