diff --git a/adapter/redis_test.go b/adapter/redis_test.go index 3817033..ca075ce 100644 --- a/adapter/redis_test.go +++ b/adapter/redis_test.go @@ -3,6 +3,7 @@ package adapter import ( "context" "testing" + "time" "github.com/redis/go-redis/v9" "github.com/stretchr/testify/assert" @@ -67,9 +68,10 @@ func TestRedis_follower_redirect_node_set_get_deleted(t *testing.T) { assert.NoError(t, res3.Err()) assert.Equal(t, int64(1), res3.Val()) - res4 := rdb.Get(ctx, string(key)) - assert.Equal(t, redis.Nil, res4.Err()) - assert.Equal(t, "", res4.Val()) + assert.Eventually(t, func() bool { + res4 := rdb.Get(ctx, string(key)) + return res4.Err() == redis.Nil && res4.Val() == "" + }, 2*time.Second, 50*time.Millisecond) } func TestRedis_leader_keys(t *testing.T) {