thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-26 17:41:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix style

Browse Source
This commit is contained in:
Kruglov Pavel 2023-02-09 14:55:21 +01:00 committed by GitHub
parent 59c52c503d
commit 947923321c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
tests/integration/helpers/cluster.py
View File

@ -4410,6 +4410,7 @@ class ClickHouseInstance:
]
)
class ClickHouseKiller(object):
def __init__(self, clickhouse_node):
self.clickhouse_node = clickhouse_node

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

@ -4541,7 +4541,7 @@ message Message {
kafka_create_topic(admin_client, f"{format_name}_err")
messages = ["qwertyuiop", "poiuytrewq", "zxcvbnm"]
kafka_produce(kafka_cluster, f'{format_name}_err', messages)
kafka_produce(kafka_cluster, f"{format_name}_err", messages)
attempt = 0
rows = 0
@ -4590,7 +4590,7 @@ struct Message
kafka_create_topic(admin_client, "CapnProto_err")
messages = ["qwertyuiop", "asdfghjkl", "zxcvbnm"]
kafka_produce(kafka_cluster, 'CapnProto_err', messages)
kafka_produce(kafka_cluster, "CapnProto_err", messages)
attempt = 0
rows = 0