Skip to content

Commit f0e5baf

Browse files
committed
Yet another fix.
1 parent 7ec48f2 commit f0e5baf

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

tests/e2e/test_operator.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -322,8 +322,8 @@ def test_operator_restart(self, manifest, service, version=None):
322322
# self.context.shell = shell
323323

324324
with Then("Data in shards should be evenly distributed"):
325-
cnt0 = clickhouse.query(chi, "select count() from clusterAllReplicas('{cluster}', default.test_local) where _shard_num in (1,3)")
326-
cnt1 = clickhouse.query(chi, "select count() from clusterAllReplicas('{cluster}', default.test_local) where _shard_num in (2,4)")
325+
cnt0 = clickhouse.query(chi, "select count() from cluster('all-sharded', default.test_local) where _shard_num in (1,2)")
326+
cnt1 = clickhouse.query(chi, "select count() from cluster('all-sharded', default.test_local) where _shard_num in (3,4)")
327327
print(f"{cnt0} {cnt1}")
328328
assert cnt0 == cnt1 and cnt0 != "0"
329329

0 commit comments

Comments
 (0)