Skip to content

Commit be98254

Browse files
committed
Disable progress notify validation until we can guarantee response
Signed-off-by: Marek Siarkowicz <[email protected]>
1 parent 68075c9 commit be98254

File tree

2 files changed

+0
-23
lines changed

2 files changed

+0
-23
lines changed

tests/robustness/client/watch.go

Lines changed: 0 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -122,21 +122,3 @@ resetWatch:
122122
}
123123
}
124124
}
125-
126-
func ValidateGotAtLeastOneProgressNotify(t *testing.T, reports []report.ClientReport, expectProgressNotify bool) {
127-
gotProgressNotify := false
128-
external:
129-
for _, r := range reports {
130-
for _, op := range r.Watch {
131-
for _, resp := range op.Responses {
132-
if resp.IsProgressNotify {
133-
gotProgressNotify = true
134-
break external
135-
}
136-
}
137-
}
138-
}
139-
if gotProgressNotify != expectProgressNotify {
140-
t.Errorf("Progress notify does not match, expect: %v, got: %v", expectProgressNotify, gotProgressNotify)
141-
}
142-
}

tests/robustness/main_test.go

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -96,11 +96,6 @@ func testRobustness(ctx context.Context, t *testing.T, lg *zap.Logger, s scenari
9696
persistedRequests, err := report.PersistedRequestsCluster(lg, c)
9797
require.NoError(t, err)
9898

99-
failpointImpactingWatch := s.Failpoint == failpoint.SleepBeforeSendWatchResponse
100-
if !failpointImpactingWatch {
101-
watchProgressNotifyEnabled := c.Cfg.ServerConfig.ExperimentalWatchProgressNotifyInterval != 0
102-
client.ValidateGotAtLeastOneProgressNotify(t, r.Client, s.Watch.RequestProgress || watchProgressNotifyEnabled)
103-
}
10499
validateConfig := validate.Config{ExpectRevisionUnique: s.Traffic.ExpectUniqueRevision()}
105100
r.Visualize = validate.ValidateAndReturnVisualize(t, lg, validateConfig, r.Client, persistedRequests, 5*time.Minute)
106101

0 commit comments

Comments
 (0)