thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-10 01:25:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix style

Browse Source
This commit is contained in:
Kruglov Pavel 2023-12-04 13:10:49 +01:00 committed by avogar
parent c6085b3eb9
commit 69f6147499
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
tests/integration/test_storage_kafka/test.py
View File

@ -4865,7 +4865,7 @@ def test_formats_errors(kafka_cluster):
"JSONColumns",
"JSONCompactColumns",
"JSONColumnsWithMetadata",
"BSONEachRow"
"BSONEachRow",
"Native",
"Arrow",
"Parquet",
@ -4905,12 +4905,20 @@ def test_formats_errors(kafka_cluster):
"""
)
kafka_produce(kafka_cluster, format_name, ["Broken message\nBroken message\nBroken message\n"])
kafka_produce(
kafka_cluster,
format_name,
["Broken message\nBroken message\nBroken message\n"]
)
attempt = 0
num_errors = 0
while attempt < 200:
num_errors = int(instance.query(f"SELECT length(exceptions.text) from system.kafka_consumers where database = 'test' and table = '{table_name}'"))
num_errors = int(
instance.query(
f"SELECT length(exceptions.text) from system.kafka_consumers where database = 'test' and table = '{table_name}'"
)
)
if num_errors > 0:
break
attempt += 1