diff --git a/cmd/spinifex/cmd/admin_kv_test.go b/cmd/spinifex/cmd/admin_kv_test.go index e7996cdfa..5197ea4c6 100644 --- a/cmd/spinifex/cmd/admin_kv_test.go +++ b/cmd/spinifex/cmd/admin_kv_test.go @@ -279,7 +279,7 @@ func TestKVDigestIgnoresExpiry(t *testing.T) { require.NoError(t, err) js, err := jetstream.New(nc) require.NoError(t, err) - kv, err := js.CreateKeyValue(ctx, jetstream.KeyValueConfig{Bucket: "ttl", TTL: time.Second}) + kv, err := js.CreateKeyValue(ctx, jetstream.KeyValueConfig{Bucket: "ttl", TTL: 200 * time.Millisecond}) require.NoError(t, err) _, err = kv.PutString(ctx, "k", "v") require.NoError(t, err) @@ -291,7 +291,7 @@ func TestKVDigestIgnoresExpiry(t *testing.T) { ns.Shutdown() ns.WaitForShutdown() - time.Sleep(1500 * time.Millisecond) + time.Sleep(400 * time.Millisecond) d, err := digestStore(ctx, work, nil, false, metas) require.NoError(t, err) require.Len(t, d, 1) diff --git a/cmd/spinifex/cmd/cluster_test.go b/cmd/spinifex/cmd/cluster_test.go index ea085d5d2..362d1152d 100644 --- a/cmd/spinifex/cmd/cluster_test.go +++ b/cmd/spinifex/cmd/cluster_test.go @@ -38,7 +38,7 @@ func TestDrainDHCPLeasesSumsReleased(t *testing.T) { _, nc, _ := testutil.StartTestJetStream(t) fakeDrainResponder(t, nc, 7, "") - released, responders := drainDHCPLeases(nc, 2*time.Second) + released, responders := drainDHCPLeases(nc, 250*time.Millisecond) assert.Equal(t, 7, released) assert.Equal(t, 1, responders) } @@ -49,7 +49,7 @@ func TestDrainDHCPLeasesReportsResponderError(t *testing.T) { // An erroring responder still counts as a responder but contributes // zero released leases. - released, responders := drainDHCPLeases(nc, 2*time.Second) + released, responders := drainDHCPLeases(nc, 250*time.Millisecond) assert.Equal(t, 0, released) assert.Equal(t, 1, responders) } diff --git a/spinifex/services/viperblockd/viperblockd_integration_test.go b/spinifex/services/viperblockd/viperblockd_integration_test.go index 016add161..1761e3d62 100644 --- a/spinifex/services/viperblockd/viperblockd_integration_test.go +++ b/spinifex/services/viperblockd/viperblockd_integration_test.go @@ -88,7 +88,7 @@ func setupTestConfig(t *testing.T, natsURL string) *Config { cfg := &Config{ NatsHost: natsURL, - S3Host: "http://127.0.0.1:1", + S3Host: fastFailingS3Host(t), Bucket: "test-bucket", Region: "us-east-1", AccessKey: "test-access-key",