fix attach partition

Author: Selfeer

alter/table/attach_partition/replica/add_remove_replica.py

@@ -32,6 +32,7 @@ def add_remove_replicas(
                 table_name=source_table_name,
                 active_replicas=active_replicas,
                 engine=engine,
+                order_by="a"
             )
         join()
 
@@ -154,13 +155,16 @@ def replica(self):
                     table_name=destination_table_name,
                     node=node,
                     engine=destination_table_engine,
+                    order_by="a",
+
                 )
 
         with And("I create source table on the first node and insert data"):
             create_one_replica(
                 table_name=source_table_name,
                 node=self.context.node_1,
                 engine=source_table_engine,
+                order_by="a",
             )
             insert_random(table_name=source_table_name, node=self.context.node_1)
             self.context.active_replicas.append(0)

alter/table/attach_partition/replica/common.py

@@ -359,11 +359,11 @@ def create_replica_on_third_node(
 
 @TestStep
 def add_remove_replica_on_first_node(
-    self, table_name, active_replicas, engine, delay_before_delete=None
+    self, table_name, active_replicas, engine, delay_before_delete=None, order_by="tuple()"
 ):
     "Create replica on first node, wait less that 2 seconds and delete replica from the node."
     create_replica_on_first_node(
-        table_name=table_name, active_replicas=active_replicas, engine=engine
+        table_name=table_name, active_replicas=active_replicas, engine=engine, order_by=order_by
     )
 
     if delay_before_delete is None:
@@ -380,11 +380,11 @@ def add_remove_replica_on_first_node(
 
 @TestStep
 def add_remove_replica_on_second_node(
-    self, table_name, active_replicas, engine, delay_before_delete=None
+    self, table_name, active_replicas, engine, delay_before_delete=None, order_by="tuple()"
 ):
     "Create replica on second node, wait less that 2 seconds and delete replica from the node."
     create_replica_on_second_node(
-        table_name=table_name, active_replicas=active_replicas, engine=engine
+        table_name=table_name, active_replicas=active_replicas, engine=engine, order_by=order_by
     )
 
     if delay_before_delete is None:
@@ -401,13 +401,14 @@ def add_remove_replica_on_second_node(
 
 @TestStep
 def add_remove_replica_on_third_node(
-    self, table_name, active_replicas, engine, delay_before_delete=None
+    self, table_name, active_replicas, engine, delay_before_delete=None, order_by="tuple()"
 ):
     "Create replica on third node, wait less that 2 seconds and delete replica from the node."
     create_replica_on_third_node(
         table_name=table_name,
         active_replicas=active_replicas,
         engine=engine,
+        order_by=order_by
     )
 
     if delay_before_delete is None:

alter/table/attach_partition/temporary_table.py

@@ -33,6 +33,7 @@ def check_attach_partition_detached_with_temporary_tables(self, table, engine):
                     engine=engine,
                     partition_by="a",
                     node=client,
+                    order_by="a"
                 )
 
                 table_before = client.query(
@@ -125,12 +126,14 @@ def check_attach_partition_from_with_temporary_tables(
                 table_name=source_table_name,
                 engine=source_table_engine,
                 partition_by="a",
+                order_by="a"
             )
         if "replicated" in destination_table.__name__:
             destination_table(
                 table_name=destination_table_name,
                 engine=destination_table_engine,
                 partition_by="a",
+                order_by="a"
             )
 
     with Given("I open a single clickhouse instance"):
@@ -152,13 +155,17 @@ def check_attach_partition_from_with_temporary_tables(
                         engine=source_table_engine,
                         partition_by="a",
                         node=client,
+                        order_by="a"
+
                     )
                 if "replicated" not in destination_table.__name__:
                     destination_table(
                         table_name=destination_table_name,
                         engine=destination_table_engine,
                         partition_by="a",
                         node=client,
+                        order_by="a"
+
                     )
 
             with And(