diff --git a/tests/robustness/validate/validate_test.go b/tests/robustness/validate/validate_test.go index 45d53be65..c124a513b 100644 --- a/tests/robustness/validate/validate_test.go +++ b/tests/robustness/validate/validate_test.go @@ -821,8 +821,6 @@ func TestValidateWatch(t *testing.T) { putPersistedEvent("b", "2", 3, true), putPersistedEvent("c", "3", 4, true), }, - // TODO: Should pass as watch with revision 0 might start from any revision. - expectError: errBrokeResumable.Error(), }, { name: "Reliable - missing last event - pass", diff --git a/tests/robustness/validate/watch.go b/tests/robustness/validate/watch.go index a43e527f5..f51caed62 100644 --- a/tests/robustness/validate/watch.go +++ b/tests/robustness/validate/watch.go @@ -176,9 +176,11 @@ func validateReliable(lg *zap.Logger, events []model.PersistedEvent, report repo func validateResumable(lg *zap.Logger, events []model.PersistedEvent, report report.ClientReport) (err error) { for _, op := range report.Watch { + if op.Request.Revision == 0 { + continue + } index := 0 - revision := op.Request.Revision - for index < len(events) && (events[index].Revision < revision || !events[index].Match(op.Request)) { + for index < len(events) && (events[index].Revision < op.Request.Revision || !events[index].Match(op.Request)) { index++ } if index == len(events) {