thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-22 07:31:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix style

Browse Source
This commit is contained in:
avogar 2023-02-27 13:01:07 +00:00
parent c6a30d23aa
commit 0ef83b10ce
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/integration/test_kafka_bad_messages/test.py
View File

@ -13,6 +13,7 @@ instance = cluster.add_instance(
with_kafka=True,
)
def kafka_create_topic(
admin_client,
topic_name,
@ -49,7 +50,7 @@ def kafka_create_topic(
def kafka_delete_topic(admin_client, topic, max_retries=50):
result = admin_client.delete_topics([topic])
for (topic, e) in result.topic_error_codes:
for topic, e in result.topic_error_codes:
if e == 0:
logging.debug(f"Topic {topic} deleted")
else:
@ -141,7 +142,6 @@ def test_bad_messages_parsing(kafka_cluster):
"BSONEachRow",
"MySQLDump",
]:
print(format_name)
kafka_create_topic(admin_client, f"{format_name}_err")