diff --git a/tests/integration/test_replace_partition/test.py b/tests/integration/test_replace_partition/test.py
index 06e7f4be82b..c87a650fce7 100644
--- a/tests/integration/test_replace_partition/test.py
+++ b/tests/integration/test_replace_partition/test.py
@@ -1,3 +1,4 @@
+import time
 import pytest
 
 from helpers.cluster import ClickHouseCluster
@@ -97,12 +98,13 @@ def test_drop_failover(drop_failover):
         # Drop partition on source node
         node3.query("ALTER TABLE test_table DROP PARTITION 201706")
 
-    # connection restored
+    # Wait few seconds for connection to zookeeper to be restored
+    time.sleep(5)
 
-    node4.query_with_retry("select last_exception from system.replication_queue where type = 'REPLACE_RANGE'",
-                           check_callback=lambda x: 'Not found part' not in x, sleep_time=1)
-    assert 'Not found part' not in node4.query(
-        "select last_exception from system.replication_queue where type = 'REPLACE_RANGE'")
+    msg = node4.query_with_retry(
+        "select last_exception from system.replication_queue where type = 'REPLACE_RANGE'",
+        check_callback=lambda x: 'Not found part' not in x, sleep_time=1)
+    assert 'Not found part' not in msg
     assert_eq_with_retry(node4, "SELECT id FROM test_table order by id", '')
 
 
@@ -151,8 +153,11 @@ def test_replace_after_replace_failover(replace_after_replace_failover):
 
         assert_eq_with_retry(node5, "SELECT id FROM test_table order by id", '333')
 
-    node6.query_with_retry("select last_exception from system.replication_queue where type = 'REPLACE_RANGE'",
-                           check_callback=lambda x: 'Not found part' not in x, sleep_time=1)
-    assert 'Not found part' not in node6.query(
-        "select last_exception from system.replication_queue where type = 'REPLACE_RANGE'")
+    # Wait few seconds for connection to zookeeper to be restored
+    time.sleep(5)
+
+    msg = node6.query_with_retry(
+        "select last_exception from system.replication_queue where type = 'REPLACE_RANGE'",
+        check_callback=lambda x: 'Not found part' not in x, sleep_time=1)
+    assert 'Not found part' not in msg
     assert_eq_with_retry(node6, "SELECT id FROM test_table order by id", '333')