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

Enable tests with broken channel.start_consuming

Browse Source
This commit is contained in:
Mikhail f. Shiryaev 2023-06-23 02:56:06 +02:00
parent 4f1982e25e
commit f85460d8ef
No known key found for this signature in database
GPG Key ID: 4B02ED204C7D93F4
1 changed files with 0 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -2953,7 +2953,6 @@ def test_rabbitmq_address(rabbitmq_cluster):
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(
"""
@ -3002,7 +3001,6 @@ def test_format_with_prefix_and_suffix(rabbitmq_cluster):
)
@pytest.mark.skip(reason="FIXME: flaky (something with channel.start_consuming()")
def test_max_rows_per_message(rabbitmq_cluster):
num_rows = 5
@ -3075,7 +3073,6 @@ def test_max_rows_per_message(rabbitmq_cluster):
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
@ -3172,7 +3169,6 @@ def test_row_based_formats(rabbitmq_cluster):
assert result == expected
@pytest.mark.skip(reason="FIXME: flaky (something with channel.start_consuming()")
def test_block_based_formats_1(rabbitmq_cluster):
instance.query(
"""
@ -3234,7 +3230,6 @@ 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):
num_rows = 100