Merge pull request #2435 from nats-io/unit-test-fail

Made test more predictable by waiting for leader after leader shutdown
This commit is contained in:
Matthias Hanel
2021-08-12 12:57:06 -04:00
committed by GitHub

View File

@@ -1975,6 +1975,7 @@ func TestNoRaceJetStreamClusterMirrorExpirationAndMissingSequences(t *testing.T)
// Now shutdown the server with the mirror.
ms := c.streamLeader("$G", "M")
ms.Shutdown()
c.waitOnLeader()
// Send more messages but let them expire.
sendBatch(10)