thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-23 16:12:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

Automatic style fix

Browse Source
This commit is contained in:
robot-clickhouse 2023-08-07 19:23:31 +00:00
parent fd69b18184
commit 9b631e2cef
1 changed files with 6 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
tests/integration/test_parallel_replicas_over_distributed/test.py
View File

@ -4,9 +4,7 @@ from helpers.cluster import ClickHouseCluster
cluster = ClickHouseCluster(__file__) cluster = ClickHouseCluster(__file__)
nodes = [ nodes = [
cluster.add_instance( cluster.add_instance(f"n{i}", main_configs=["configs/remote_servers.xml"])
f"n{i}", main_configs=["configs/remote_servers.xml"]
)
for i in (1, 2, 3, 4) for i in (1, 2, 3, 4)
] ]
@ -40,21 +38,11 @@ def create_tables(cluster):
""" """
) )
nodes[0].query( nodes[0].query(f"INSERT INTO test_table SELECT number, number FROM numbers(1000)")
f"INSERT INTO test_table SELECT number, number FROM numbers(1000)" nodes[1].query(f"INSERT INTO test_table SELECT number, number FROM numbers(2000)")
) nodes[2].query(f"INSERT INTO test_table SELECT -number, -number FROM numbers(1000)")
nodes[1].query( nodes[3].query(f"INSERT INTO test_table SELECT -number, -number FROM numbers(2000)")
f"INSERT INTO test_table SELECT number, number FROM numbers(2000)" nodes[0].query(f"INSERT INTO test_table SELECT number, number FROM numbers(1)")
)
nodes[2].query(
f"INSERT INTO test_table SELECT -number, -number FROM numbers(1000)"
)
nodes[3].query(
f"INSERT INTO test_table SELECT -number, -number FROM numbers(2000)"
)
nodes[0].query(
f"INSERT INTO test_table SELECT number, number FROM numbers(1)"
)
@pytest.mark.parametrize( @pytest.mark.parametrize(
@ -62,7 +50,6 @@ def create_tables(cluster):
["test_multiple_shards_multiple_replicas", "test_single_shard_multiple_replicas"], ["test_multiple_shards_multiple_replicas", "test_single_shard_multiple_replicas"],
) )
def test_parallel_replicas_custom_key(start_cluster, cluster): def test_parallel_replicas_custom_key(start_cluster, cluster):
create_tables(cluster) create_tables(cluster)
expected_result = f"6001\t-1999\t1999\t0\n" expected_result = f"6001\t-1999\t1999\t0\n"