diff --git a/tests/robustness/watch.go b/tests/robustness/watch.go index 45869446f..3da853f00 100644 --- a/tests/robustness/watch.go +++ b/tests/robustness/watch.go @@ -129,13 +129,11 @@ func validateGotAtLeastOneProgressNotify(t *testing.T, reports []report.ClientRe external: for _, r := range reports { for _, op := range r.Watch { - var lastHeadRevision int64 = 1 for _, resp := range op.Responses { - if resp.IsProgressNotify && resp.Revision == lastHeadRevision { + if resp.IsProgressNotify { gotProgressNotify = true break external } - lastHeadRevision = resp.Revision } } }