Skip to content

Commit 5b73a8d

Browse files
committed
Reduce to 150K and add debug message
1 parent 77087bf commit 5b73a8d

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

tests/integration/test_storage_rabbitmq/test_failed_connection.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,7 @@ def test_rabbitmq_restore_failed_connection_without_losses_1(rabbitmq_cluster):
110110
"""
111111
)
112112

113-
messages_num = 200000
113+
messages_num = 150000
114114
values = []
115115
for i in range(messages_num):
116116
values.append("({i}, {i})".format(i=i))
@@ -152,6 +152,7 @@ def test_rabbitmq_restore_failed_connection_without_losses_1(rabbitmq_cluster):
152152
result = instance.query("SELECT count(DISTINCT key) FROM test.view")
153153
if int(result) == messages_num:
154154
break
155+
logging.debug(f"Result: {result} / {messages_num}")
155156
time.sleep(1)
156157
else:
157158
pytest.fail(
@@ -192,7 +193,7 @@ def test_rabbitmq_restore_failed_connection_without_losses_2(rabbitmq_cluster):
192193
"""
193194
)
194195

195-
messages_num = 200000
196+
messages_num = 150000
196197

197198
messages = []
198199
for i in range(messages_num):

0 commit comments

Comments
 (0)