thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-12 09:22:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' into ADQM-639

Browse Source
This commit is contained in:
Roman Vasin 2023-02-07 13:30:14 +03:00 committed by GitHub
commit e20d3ce6fc
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/integration/test_storage_rabbitmq/test.py
View File

@ -2953,6 +2953,7 @@ def test_rabbitmq_address(rabbitmq_cluster):
instance2.query("drop table rabbit_out 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): def test_format_with_prefix_and_suffix(rabbitmq_cluster):
instance.query( instance.query(
""" """
@ -3001,7 +3002,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): def test_max_rows_per_message(rabbitmq_cluster):
num_rows = 5 num_rows = 5
@ -3074,6 +3075,7 @@ def test_max_rows_per_message(rabbitmq_cluster):
assert result == "0\t0\n10\t100\n20\t200\n30\t300\n40\t400\n" 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): def test_row_based_formats(rabbitmq_cluster):
num_rows = 10 num_rows = 10
@ -3170,6 +3172,7 @@ def test_row_based_formats(rabbitmq_cluster):
assert result == expected assert result == expected
@pytest.mark.skip(reason="FIXME: flaky (something with channel.start_consuming()")
def test_block_based_formats_1(rabbitmq_cluster): def test_block_based_formats_1(rabbitmq_cluster):
instance.query( instance.query(
""" """
@ -3231,6 +3234,7 @@ def test_block_based_formats_1(rabbitmq_cluster):
] ]
@pytest.mark.skip(reason="FIXME: flaky (something with channel.start_consuming()")
def test_block_based_formats_2(rabbitmq_cluster): def test_block_based_formats_2(rabbitmq_cluster):
num_rows = 100 num_rows = 100