[FIXED] Allow time for the 3rd replica to be current - TestJetStreamClusterStaleReadsOnRestart (#4513)

Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2023-09-11 22:19:01 -07:00
committed by GitHub

View File

@@ -7096,8 +7096,10 @@ func TestJetStreamClusterStaleReadsOnRestart(t *testing.T) {
c.restartServer(sl)
c.waitOnAllCurrent()
var state StreamState
// Allow the 3rd replica to be current.
time.Sleep(250 * time.Millisecond)
var state StreamState
for _, s := range c.servers {
if s.Running() {
mset, err := s.GlobalAccount().lookupStream("TEST")