diff --git a/server/jetstream_cluster_test.go b/server/jetstream_cluster_test.go index b00c961a..535fb8e5 100644 --- a/server/jetstream_cluster_test.go +++ b/server/jetstream_cluster_test.go @@ -3530,7 +3530,7 @@ func TestJetStreamClusterRemovePeer(t *testing.T) { t.Fatalf("Unexpected error: %v", err) } - checkFor(t, 5*time.Second, 100*time.Millisecond, func() error { + checkFor(t, 20*time.Second, 100*time.Millisecond, func() error { si, err := js.StreamInfo("TEST") if err != nil { return fmt.Errorf("Could not fetch stream info: %v", err) @@ -4351,7 +4351,7 @@ func TestJetStreamCrossAccountMirrorsAndSources(t *testing.T) { t.Fatalf("Unexpected error: %v", err) } - checkFor(t, 2*time.Second, 100*time.Millisecond, func() error { + checkFor(t, 20*time.Second, 100*time.Millisecond, func() error { si, err := js2.StreamInfo("MY_MIRROR_TEST") if err != nil { t.Fatalf("Could not retrieve stream info") @@ -4393,7 +4393,7 @@ func TestJetStreamCrossAccountMirrorsAndSources(t *testing.T) { t.Fatalf("Did not receive correct response: %+v", scResp.Error) } - checkFor(t, 2*time.Second, 100*time.Millisecond, func() error { + checkFor(t, 20*time.Second, 100*time.Millisecond, func() error { si, err := js2.StreamInfo("MY_SOURCE_TEST") if err != nil { t.Fatalf("Could not retrieve stream info")