Merge branch 'main' of github.com:Altinity/clickhouse-regression

s3/tests/alter.py

@@ -180,6 +180,12 @@ def order_by(self):
             exitcode=0,
         )
 
+    with And("I check the number of rows on all nodes"):
+        for node in nodes:
+            retry(assert_row_count, **retry_args)(
+                node=node, table_name=table_name, rows=INSERT_SIZE
+            )
+
 
 @TestScenario
 def sample_by(self):
@@ -206,6 +212,12 @@ def sample_by(self):
             exitcode=0,
         )
 
+    with And("I check the number of rows on all nodes"):
+        for node in nodes:
+            retry(assert_row_count, **retry_args)(
+                node=node, table_name=table_name, rows=INSERT_SIZE
+            )
+
 
 @TestScenario
 def index(self):
@@ -251,6 +263,12 @@ def index(self):
                 exitcode=0,
             )
 
+    with Then("I check the number of rows on all nodes"):
+        for node in nodes:
+            retry(assert_row_count, **retry_args)(
+                node=node, table_name=table_name, rows=INSERT_SIZE
+            )
+
 
 @TestScenario
 def projection(self):
@@ -292,6 +310,12 @@ def projection(self):
             exitcode=0,
         )
 
+    with And("I check the number of rows on all nodes"):
+        for node in nodes:
+            retry(assert_row_count, **retry_args)(
+                node=node, table_name=table_name, rows=INSERT_SIZE
+            )
+
 
 @TestOutline(Scenario)
 @Examples("partition", [[""], ["PARTITION 1"]])
@@ -797,7 +821,10 @@ def columns(self):
         assert "column comment" not in r.output, error(r)
 
     with And("The table should contain all rows"):
-        assert_row_count(node=nodes[2], table_name=table_name, rows=INSERT_SIZE)
+        for node in nodes:
+            retry(assert_row_count, **retry_args)(
+                node=node, table_name=table_name, rows=INSERT_SIZE
+            )
 
 
 @TestFeature