99from helpers .cluster import ClickHouseCluster
1010
1111DEFAULT_TIMEOUT_SEC = 120
12- RABBITMQ_CONSUMPTION_TIMEOUT_SEC = 240
12+ CLICKHOUSE_VIEW_TIMEOUT_SEC = 240
1313
1414cluster = ClickHouseCluster (__file__ )
1515instance = cluster .add_instance (
@@ -252,7 +252,7 @@ def test_rabbitmq_restore_failed_connection_without_losses_1(rabbitmq_cluster, r
252252
253253 resume_rabbitmq (rabbitmq_cluster , rabbitmq_monitor )
254254
255- deadline = time .monotonic () + RABBITMQ_CONSUMPTION_TIMEOUT_SEC
255+ deadline = time .monotonic () + CLICKHOUSE_VIEW_TIMEOUT_SEC
256256 while time .monotonic () < deadline :
257257 result = instance .query ("SELECT count(DISTINCT key) FROM test.view" )
258258 if int (result ) == messages_num :
@@ -261,7 +261,7 @@ def test_rabbitmq_restore_failed_connection_without_losses_1(rabbitmq_cluster, r
261261 time .sleep (1 )
262262 else :
263263 pytest .fail (
264- f"Time limit of { RABBITMQ_CONSUMPTION_TIMEOUT_SEC } seconds reached. The result did not match the expected value."
264+ f"Time limit of { CLICKHOUSE_VIEW_TIMEOUT_SEC } seconds reached. The result did not match the expected value."
265265 )
266266
267267 instance .query (
@@ -349,7 +349,7 @@ def test_rabbitmq_restore_failed_connection_without_losses_2(rabbitmq_cluster, r
349349 # kill_rabbitmq()
350350 # revive_rabbitmq()
351351
352- deadline = time .monotonic () + RABBITMQ_CONSUMPTION_TIMEOUT_SEC
352+ deadline = time .monotonic () + CLICKHOUSE_VIEW_TIMEOUT_SEC
353353 while time .monotonic () < deadline :
354354 result = instance .query ("SELECT count(DISTINCT key) FROM test.view" ).strip ()
355355 if int (result ) == messages_num :
@@ -358,7 +358,7 @@ def test_rabbitmq_restore_failed_connection_without_losses_2(rabbitmq_cluster, r
358358 time .sleep (1 )
359359 else :
360360 pytest .fail (
361- f"Time limit of { RABBITMQ_CONSUMPTION_TIMEOUT_SEC } seconds reached. The result did not match the expected value."
361+ f"Time limit of { CLICKHOUSE_VIEW_TIMEOUT_SEC } seconds reached. The result did not match the expected value."
362362 )
363363
364364 instance .query (
0 commit comments