Allow time for the 3rd replica to be current

Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2023-09-11 21:54:58 -07:00
parent e72bb957fd
commit eed5fd8a73

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")