Revert change in test

This commit is contained in:
Nikolai Kochetov 2021-10-12 19:15:27 +03:00
parent f2d8cc547f
commit f845ee38d0

View File

@ -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;