From 165f3e297b14a71c73cc605cead15ad964494694 Mon Sep 17 00:00:00 2001 From: liuyuecai Date: Thu, 14 Mar 2024 20:53:51 +0800 Subject: [PATCH] add timeout param --- tests/integration/replication_test.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/tests/integration/replication_test.go b/tests/integration/replication_test.go index 41b802c778..8ee0e30314 100644 --- a/tests/integration/replication_test.go +++ b/tests/integration/replication_test.go @@ -430,10 +430,10 @@ var _ = Describe("should replication ", func() { Expect(err1).NotTo(HaveOccurred()) Eventually(func() error { return clientMaster.Get(ctx, "key").Err() - }, "20s", "100ms").Should(Equal(redis.Nil)) + }, "61s", "100ms").Should(Equal(redis.Nil)) Eventually(func() error { return clientSlave.Get(ctx, "key").Err() - }, "20s", "100ms").Should(Equal(redis.Nil)) + }, "61s", "100ms").Should(Equal(redis.Nil)) log.Println("Replication test 1 success") log.Println("Replication test 2 start") @@ -446,10 +446,10 @@ var _ = Describe("should replication ", func() { Expect(clientMaster.FlushDB(ctx).Err()).NotTo(HaveOccurred()) Eventually(func() error { return clientMaster.Get(ctx, "x").Err() - }, "20s", "100ms").Should(Equal(redis.Nil)) + }, "61s", "100ms").Should(Equal(redis.Nil)) Eventually(func() error { return clientSlave.Get(ctx, "x").Err() - }, "20s", "100ms").Should(Equal(redis.Nil)) + }, "61s", "100ms").Should(Equal(redis.Nil)) log.Println("Replication test 2 success") log.Println("rpoplpush test start")