fix: cut fixed waits from viperblockd and cmd tests

This commit is contained in:
Julian Sommer
2026-09-30 15:42:48 +10:00
parent 8a1045b4e7
commit dc636cac63
3 changed files with 5 additions and 5 deletions
+2 -2
View File
@@ -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)
+2 -2
View File
@@ -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)
}
@@ -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",