Skip to content

Commit 49f128c

Browse files
committed
Change to resp 2
1 parent 80bced9 commit 49f128c

File tree

1 file changed

+6
-11
lines changed

1 file changed

+6
-11
lines changed

timeseries_commands_test.go

Lines changed: 6 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -14,26 +14,21 @@ var _ = Describe("RedisTimeseries commands", Label("timeseries"), func() {
1414
ctx := context.TODO()
1515
var client *redis.Client
1616

17-
setupRedisClient := func(protocolVersion int) *redis.Client {
18-
return redis.NewClient(&redis.Options{
19-
Addr: "localhost:6379",
20-
DB: 0,
21-
Protocol: protocolVersion,
22-
UnstableResp3: true,
23-
})
24-
}
25-
2617
AfterEach(func() {
2718
if client != nil {
2819
client.FlushDB(ctx)
2920
client.Close()
3021
}
3122
})
3223

33-
protocols := []int{2, 3}
24+
protocols := []int{2}
3425
for _, protocol := range protocols {
3526
BeforeEach(func() {
36-
client = setupRedisClient(protocol)
27+
client = redis.NewClient(&redis.Options{
28+
Addr: "localhost:6379",
29+
DB: 0,
30+
Protocol: protocol,
31+
})
3732
Expect(client.FlushAll(ctx).Err()).NotTo(HaveOccurred())
3833
})
3934

0 commit comments

Comments
 (0)