From d52420c5481a2f6cb0ae3742d87156acf69266f6 Mon Sep 17 00:00:00 2001 From: Kseniia Sumarokova <54203879+kssenii@users.noreply.github.com> Date: Mon, 6 Feb 2023 14:10:33 +0100 Subject: [PATCH 1/2] Update test.py --- tests/integration/test_storage_rabbitmq/test.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/tests/integration/test_storage_rabbitmq/test.py b/tests/integration/test_storage_rabbitmq/test.py index 7df3509a6f2..241de57c34e 100644 --- a/tests/integration/test_storage_rabbitmq/test.py +++ b/tests/integration/test_storage_rabbitmq/test.py @@ -2952,7 +2952,7 @@ def test_rabbitmq_address(rabbitmq_cluster): instance2.query("drop table rabbit_in sync") instance2.query("drop table rabbit_out sync") - +@pytest.mark.skip(reason="FIXME: flaky (something with channel.start_consuming()") def test_format_with_prefix_and_suffix(rabbitmq_cluster): instance.query( """ @@ -3001,7 +3001,7 @@ def test_format_with_prefix_and_suffix(rabbitmq_cluster): ) -@pytest.mark.skip(reason="FIXME: broken") +@pytest.mark.skip(reason="FIXME: flaky (something with channel.start_consuming()") def test_max_rows_per_message(rabbitmq_cluster): num_rows = 5 @@ -3073,7 +3073,7 @@ def test_max_rows_per_message(rabbitmq_cluster): result = instance.query("SELECT * FROM test.view") assert result == "0\t0\n10\t100\n20\t200\n30\t300\n40\t400\n" - +@pytest.mark.skip(reason="FIXME: flaky (something with channel.start_consuming()") def test_row_based_formats(rabbitmq_cluster): num_rows = 10 @@ -3169,7 +3169,7 @@ def test_row_based_formats(rabbitmq_cluster): result = instance.query("SELECT * FROM test.view") assert result == expected - +@pytest.mark.skip(reason="FIXME: flaky (something with channel.start_consuming()") def test_block_based_formats_1(rabbitmq_cluster): instance.query( """ @@ -3230,7 +3230,7 @@ def test_block_based_formats_1(rabbitmq_cluster): ["40", "400"], ] - +@pytest.mark.skip(reason="FIXME: flaky (something with channel.start_consuming()") def test_block_based_formats_2(rabbitmq_cluster): num_rows = 100 From 7aeacabe2f07fab121905ebe6701b4d6621e7040 Mon Sep 17 00:00:00 2001 From: robot-clickhouse Date: Mon, 6 Feb 2023 13:20:15 +0000 Subject: [PATCH 2/2] Automatic style fix --- tests/integration/test_storage_rabbitmq/test.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/tests/integration/test_storage_rabbitmq/test.py b/tests/integration/test_storage_rabbitmq/test.py index 241de57c34e..f354ae01714 100644 --- a/tests/integration/test_storage_rabbitmq/test.py +++ b/tests/integration/test_storage_rabbitmq/test.py @@ -2952,6 +2952,7 @@ def test_rabbitmq_address(rabbitmq_cluster): instance2.query("drop table rabbit_in sync") instance2.query("drop table rabbit_out sync") + @pytest.mark.skip(reason="FIXME: flaky (something with channel.start_consuming()") def test_format_with_prefix_and_suffix(rabbitmq_cluster): instance.query( @@ -3073,6 +3074,7 @@ def test_max_rows_per_message(rabbitmq_cluster): result = instance.query("SELECT * FROM test.view") assert result == "0\t0\n10\t100\n20\t200\n30\t300\n40\t400\n" + @pytest.mark.skip(reason="FIXME: flaky (something with channel.start_consuming()") def test_row_based_formats(rabbitmq_cluster): num_rows = 10 @@ -3169,6 +3171,7 @@ def test_row_based_formats(rabbitmq_cluster): result = instance.query("SELECT * FROM test.view") assert result == expected + @pytest.mark.skip(reason="FIXME: flaky (something with channel.start_consuming()") def test_block_based_formats_1(rabbitmq_cluster): instance.query( @@ -3230,6 +3233,7 @@ def test_block_based_formats_1(rabbitmq_cluster): ["40", "400"], ] + @pytest.mark.skip(reason="FIXME: flaky (something with channel.start_consuming()") def test_block_based_formats_2(rabbitmq_cluster): num_rows = 100