thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-24 00:22:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix tests

Browse Source
This commit is contained in:
kssenii 2022-12-23 11:47:51 +01:00
parent ab458e68cd
commit 8f1145f6e4
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tests/integration/test_storage_rabbitmq/test.py
View File

@ -627,7 +627,7 @@ def test_rabbitmq_sharding_between_queues_publish(rabbitmq_cluster):
ENGINE = RabbitMQ ENGINE = RabbitMQ
SETTINGS rabbitmq_host_port = 'rabbitmq1:5672', SETTINGS rabbitmq_host_port = 'rabbitmq1:5672',
rabbitmq_exchange_name = 'test_sharding', rabbitmq_exchange_name = 'test_sharding',
rabbitmq_num_queues = 10, rabbitmq_num_queues = 5,
rabbitmq_num_consumers = 10, rabbitmq_num_consumers = 10,
rabbitmq_max_block_size = 100, rabbitmq_max_block_size = 100,
rabbitmq_flush_interval_ms=10000, rabbitmq_flush_interval_ms=10000,
@ -671,7 +671,7 @@ def test_rabbitmq_sharding_between_queues_publish(rabbitmq_cluster):
connection.close() connection.close()
threads = [] threads = []
threads_num = 20 threads_num = 10
for _ in range(threads_num): for _ in range(threads_num):
threads.append(threading.Thread(target=produce)) threads.append(threading.Thread(target=produce))
@ -696,7 +696,7 @@ def test_rabbitmq_sharding_between_queues_publish(rabbitmq_cluster):
assert ( assert (
int(result1) == messages_num * threads_num int(result1) == messages_num * threads_num
), "ClickHouse lost some messages: {}".format(result) ), "ClickHouse lost some messages: {}".format(result)
assert int(result2) == 10 assert int(result2) == 5
def test_rabbitmq_mv_combo(rabbitmq_cluster): def test_rabbitmq_mv_combo(rabbitmq_cluster):
@ -1025,10 +1025,10 @@ def test_rabbitmq_overloaded_insert(rabbitmq_cluster):
rabbitmq_exchange_name = 'over', rabbitmq_exchange_name = 'over',
rabbitmq_queue_base = 'over', rabbitmq_queue_base = 'over',
rabbitmq_exchange_type = 'direct', rabbitmq_exchange_type = 'direct',
rabbitmq_num_consumers = 5, rabbitmq_num_consumers = 3,
rabbitmq_flush_interval_ms=1000, rabbitmq_flush_interval_ms=1000,
rabbitmq_max_block_size = 100, rabbitmq_max_block_size = 100,
rabbitmq_num_queues = 10, rabbitmq_num_queues = 2,
rabbitmq_routing_key_list = 'over', rabbitmq_routing_key_list = 'over',
rabbitmq_format = 'TSV', rabbitmq_format = 'TSV',
rabbitmq_row_delimiter = '\\n'; rabbitmq_row_delimiter = '\\n';