From 4c1bb4d7c75c28a3c1ffa96b5da7879f6170f593 Mon Sep 17 00:00:00 2001 From: alsu Date: Mon, 30 Sep 2024 12:09:20 +0200 Subject: [PATCH] minor update to attach partition test --- .../operations_on_attached_partition.py | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/alter/table/attach_partition/operations_on_attached_partition.py b/alter/table/attach_partition/operations_on_attached_partition.py index b3e4326f1..ba9f7d6dc 100644 --- a/alter/table/attach_partition/operations_on_attached_partition.py +++ b/alter/table/attach_partition/operations_on_attached_partition.py @@ -232,14 +232,14 @@ def attach_partition_from_table( with Then( f"I check that partitions were attached when source table partition_id - {source_partition_key}, destination table partition key - {destination_partition_key}, source table engine - {self.context.source_engine}, destination table engine - {self.context.destination_engine}:" ): - source_partition_data = get_node(self, "source").query( - f"SELECT * FROM {source_table_name} ORDER BY tuple(*) FORMAT TabSeparated" - ) - destination_partition_data = get_node(self, "destination").query( - f"SELECT * FROM {destination_table_name} ORDER BY tuple(*) FORMAT TabSeparated" - ) for attempt in retries(timeout=300, delay=10): with attempt: + source_partition_data = get_node(self, "source").query( + f"SELECT * FROM {source_table_name} ORDER BY tuple(*) FORMAT TabSeparated" + ) + destination_partition_data = get_node(self, "destination").query( + f"SELECT * FROM {destination_table_name} ORDER BY tuple(*) FORMAT TabSeparated" + ) assert ( destination_partition_data.output == source_partition_data.output @@ -683,7 +683,7 @@ def check_multiple_attach_move_partition( data_after = self.context.node_1.query( f"SELECT * FROM {new_destination_table_name} ORDER BY tuple(*) FORMAT TabSeparated" ) - for attempt in retries(timeout=30, delay=2): + for attempt in retries(timeout=300, delay=20): with attempt: assert data_after.output == data_before, error()