diff --git a/nomad/leader_test.go b/nomad/leader_test.go index 475da47b0..b753b41f4 100644 --- a/nomad/leader_test.go +++ b/nomad/leader_test.go @@ -228,6 +228,7 @@ func TestLeader_EvalBroker_Reset(t *testing.T) { defer s3.Shutdown() servers := []*Server{s1, s2, s3} testJoin(t, s1, s2, s3) + testutil.WaitForLeader(t, s1.RPC) for _, s := range servers { testutil.WaitForResult(func() (bool, error) {