Merge pull request #1933 from smira/fix/endless-loop

fix: break the watch loop when the watch fails
vmware-tanzu · Oct 18, 2023 · e5bb561 · e5bb561
2 parents e0a409a + e20e6bb
commit e5bb561
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pkg/client/logs.go b/pkg/client/logs.go
@@ -204,7 +204,11 @@ func watchPodsToStreamLogs(client kubernetes.Interface, cfg *LogConfig, podCh ch
 
 	go func() {
 		for {
-			v := <-ch
+			v, ok := <-ch
+			if !ok {
+				break
+			}
+
 			if v.Type == watch.Added && v.Object != nil {
 				switch t := v.Object.(type) {
 				case *v1.Pod: