diff --git a/pkg/kube/client.go b/pkg/kube/client.go index 13be438e1..433aae14c 100644 --- a/pkg/kube/client.go +++ b/pkg/kube/client.go @@ -949,7 +949,10 @@ func (c *Client) watchPodUntilComplete(timeout time.Duration, info *resource.Inf // GetPodLogs takes pod name and namespace and returns the current logs (streaming is NOT enabled). func (c *Client) GetPodLogs(name, ns string) (string, error) { - client, _ := c.KubernetesClientSet() + client, err := c.KubernetesClientSet() + if err != nil { + return "", err + } req := client.CoreV1().Pods(ns).GetLogs(name, &v1.PodLogOptions{}) podLogs, err := req.Stream() if err != nil {