tuning flacky test

ravendb · Aug 26, 2024 · 4797e53 · 4797e53
1 parent d109bf5
commit 4797e53
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/test/java/net/ravendb/client/test/server/replication/PullReplicationTest.java b/src/test/java/net/ravendb/client/test/server/replication/PullReplicationTest.java
@@ -171,7 +171,7 @@ public void updatePullReplicationOnSink() throws Exception {
                     String definitionName1 = "pull-replication " + hub.getDatabase();
                     String definitionName2 = "pull-replication " + hub2.getDatabase();
 
-                    int timeout = 3_000;
+                    int timeout = 15_000;
 
                     hub.maintenance().forDatabase(hub.getDatabase()).send(new PutPullReplicationAsHubOperation(definitionName1));
                     hub2.maintenance().forDatabase(hub2.getDatabase()).send(new PutPullReplicationAsHubOperation(definitionName2));
@@ -281,6 +281,8 @@ public void disablePullReplicationOnSink() throws Exception {
 
                 addWatcherToReplicationTopology(sink, pull, hub.getUrls());
 
+                Thread.sleep(500); // wait a bit to process updates
+
                 try (IDocumentSession main = hub.openSession()) {
                     main.store(new User(), "hub/2");
                     main.saveChanges();
@@ -292,6 +294,8 @@ public void disablePullReplicationOnSink() throws Exception {
                 pull.setDisabled(false);
                 addWatcherToReplicationTopology(sink, pull, hub.getUrls());
 
+                Thread.sleep(500); // wait a bit to process updates
+
                 try (IDocumentSession main = hub.openSession()) {
                     main.store(new User(), "hub/3");
                     main.saveChanges();