add timeout param

OpenAtomFoundation · Mar 14, 2024 · 165f3e2 · 165f3e2
1 parent e022adc
commit 165f3e2
Showing 1 changed file with 4 additions and 4 deletions.
diff --git 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")