We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f709d58 commit 809109bCopy full SHA for 809109b
housewatch/clickhouse/backups.py
@@ -36,7 +36,7 @@ def execute_backup(
36
nodes = get_node_per_shard(cluster)
37
responses = []
38
for shard, node in nodes:
39
- params["shard"] = shard
+ params["shard"] = shard if is_sharded else "noshard"
40
if base_backup:
41
query_settings["base_backup"] = f"S3('{base_backup}/{shard}', '{aws_key}', '{aws_secret}')"
42
final_query = query % (params or {}) if substitute_params else query
housewatch/clickhouse/clusters.py
@@ -48,4 +48,5 @@ def get_node_per_shard(cluster):
48
break
49
if not preferred_replica_found:
50
nodes.append((shard, random.choice(n)))
51
+ random.shuffle(nodes)
52
return nodes
0 commit comments