Skip to content

Commit

Permalink
Remove logging from pod watcher to avoid race conditions. (#1506)
Browse files Browse the repository at this point in the history
  • Loading branch information
markusthoemmes authored Jul 16, 2020
1 parent cb729b8 commit f1b8240
Showing 1 changed file with 0 additions and 3 deletions.
3 changes: 0 additions & 3 deletions test/logstream/kubelogs.go
Original file line number Diff line number Diff line change
Expand Up @@ -113,16 +113,13 @@ func (k *kubelogs) watchPods(t test.TLegacy) {
watchedPods.Delete(p.Name)
case watch.Added, watch.Modified:
if watchedPods.Has(p.Name) {
t.Log("Already watching pod", p.Name)
continue
}
if podIsReady(p) {
t.Log("Watching logs for pod: ", p.Name)
watchedPods.Insert(p.Name)
k.startForPod(&eg, p)
continue
}
t.Log("Pod is not yet ready: ", p.Name)
}
}
}()
Expand Down

0 comments on commit f1b8240

Please sign in to comment.