From f845ee38d021052347b44e238c9356e4749ed611 Mon Sep 17 00:00:00 2001 From: Nikolai Kochetov Date: Tue, 12 Oct 2021 19:15:27 +0300 Subject: [PATCH] Revert change in test --- tests/integration/test_storage_rabbitmq/test.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/tests/integration/test_storage_rabbitmq/test.py b/tests/integration/test_storage_rabbitmq/test.py index 85dda2fe4d3..9e2752438f8 100644 --- a/tests/integration/test_storage_rabbitmq/test.py +++ b/tests/integration/test_storage_rabbitmq/test.py @@ -463,13 +463,11 @@ def test_rabbitmq_big_message(rabbitmq_cluster): for message in messages: channel.basic_publish(exchange='big', routing_key='', body=message) - for _ in range(300): + while True: result = instance.query('SELECT count() FROM test.view') if int(result) == batch_messages * rabbitmq_messages: break - time.sleep(1) - connection.close() instance.query(''' DROP TABLE test.consumer;