diff --git a/tests/integration/v3_watch_test.go b/tests/integration/v3_watch_test.go index ead81abc174..7d98b2d4f41 100644 --- a/tests/integration/v3_watch_test.go +++ b/tests/integration/v3_watch_test.go @@ -968,6 +968,8 @@ func TestV3WatchProgressOnMemberRestart(t *testing.T) { t.Log("Waiting for result") select { + case <-progressNotifyC: + t.Log("Progress notification received") case err := <-errC: t.Fatal(err) case <-doneC: