fix syntax error

This commit is contained in:
Guillaume Tassery 2019-10-23 06:39:44 +02:00
parent 5600af3391
commit c42d8a4c23

View File

@ -12,8 +12,7 @@ CLICKHOUSE_DATABASE = os.environ["CLICKHOUSE_DATABASE"]
def initialize_database(nodes, shard):
for node in nodes:
node.query((
f'''
node.query(f'''
CREATE DATABASE {CLICKHOUSE_DATABASE};
CREATE TABLE src (p UInt64, d UInt64)
ENGINE = ReplicatedMergeTree('/clickhouse/{CLICKHOUSE_DATABASE}/tables/test{shard}/replicated', '{replica}')