fix: temporary fix apache#2473

PokIsemaine · Aug 7, 2024 · 197cb41 · 197cb41
1 parent 38dfc04
commit 197cb41
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 1 deletion.
diff --git a/tests/gocase/unit/protocol/regression_test.go b/tests/gocase/unit/protocol/regression_test.go
@@ -23,6 +23,7 @@ import (
 	"context"
 	"fmt"
 	"testing"
+	"time"
 
 	"github.com/apache/kvrocks/tests/gocase/util"
 	"github.com/stretchr/testify/require"
@@ -41,7 +42,8 @@ func TestRegression(t *testing.T) {
 
 	proto := "*3\r\n$5\r\nBLPOP\r\n$6\r\nhandle\r\n$1\r\n0\r\n"
 	require.NoError(t, c.Write(fmt.Sprintf("%s%s", proto, proto)))
-
+	// TODO: Remove time.Sleep after fix issue #2473
+	time.Sleep(100 * time.Millisecond)
 	resList := []string{"*2", "$6", "handle", "$1", "a"}
 
 	v := rdb.RPush(ctx, "handle", "a")

diff --git a/tests/gocase/unit/type/list/list_test.go b/tests/gocase/unit/type/list/list_test.go
@@ -324,6 +324,7 @@ func TestList(t *testing.T) {
 			rd := srv.NewTCPClient()
 			defer func() { require.NoError(t, rd.Close()) }()
 			createList("blist", []string{"a", "b", large, "c", "d"})
+			// TODO: Remove time.Sleep after fix issue #2473
 			time.Sleep(100 * time.Millisecond)
 			require.NoError(t, rd.WriteArgs("blpop", "blist", "1"))
 			time.Sleep(100 * time.Millisecond)

diff --git a/tests/gocase/unit/type/zset/zset_test.go b/tests/gocase/unit/type/zset/zset_test.go
@@ -332,6 +332,7 @@ func basicTests(t *testing.T, rdb *redis.Client, ctx context.Context, enabledRES
 		rdb.ZAdd(ctx, "zsetb", redis.Z{Score: 1, Member: "d"}, redis.Z{Score: 2, Member: "e"})
 		require.EqualValues(t, 3, rdb.ZCard(ctx, "zseta").Val())
 		require.EqualValues(t, 2, rdb.ZCard(ctx, "zsetb").Val())
+		// TODO: Remove time.Sleep after fix issue #2473
 		time.Sleep(time.Millisecond * 100)
 		resultz := rdb.BZPopMin(ctx, 0, "zseta", "zsetb").Val().Z
 		require.Equal(t, redis.Z{Score: 1, Member: "a"}, resultz)