From 42b02db7aab5c67d927fcb393c604071c8c56cf4 Mon Sep 17 00:00:00 2001 From: James Greenhill Date: Fri, 8 Sep 2023 15:04:22 -0700 Subject: [PATCH] chore: use shard in query namespacing for backup (#44) --- housewatch/clickhouse/client.py | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/housewatch/clickhouse/client.py b/housewatch/clickhouse/client.py index 9464f7e..3496f0b 100644 --- a/housewatch/clickhouse/client.py +++ b/housewatch/clickhouse/client.py @@ -36,6 +36,8 @@ def run_query_on_shards( nodes = get_node_per_shard(cluster) responses = [] for shard, node in nodes: + params["shard"] = shard + final_query = query % (params or {}) if substitute_params else query client = Client( host=node["host_address"], database=settings.CLICKHOUSE_DATABASE, @@ -47,10 +49,7 @@ def run_query_on_shards( send_receive_timeout=30, password=settings.CLICKHOUSE_PASSWORD, ) - params["shard"] = shard - result = client.execute( - query, params=params, settings=query_settings, with_column_types=True, query_id=query_id - ) + result = client.execute(final_query, settings=query_settings, with_column_types=True, query_id=query_id) response = [] for res in result[0]: item = {}