diff --git a/logs/watcher_test.go b/logs/watcher_test.go index 6da08c6..d37dd9c 100644 --- a/logs/watcher_test.go +++ b/logs/watcher_test.go @@ -109,6 +109,8 @@ func TestWatcherClosedChannel(t *testing.T) { } func TestWatcherWithPodWatcher(t *testing.T) { + // TODO: use watcher.Close() to clean up watcher instead of relying on + // context, which leads to occasional race conditions in tests. ctx, cancel := context.WithTimeout(context.Background(), time.Second*2) defer cancel()