Skip to content

Commit 56a23e6

Browse files
authored
Resolved post-merge hiccup
1 parent e7cbf85 commit 56a23e6

File tree

1 file changed

+8
-1
lines changed
  • tests/integration/test_storage_iceberg

1 file changed

+8
-1
lines changed

tests/integration/test_storage_iceberg/test.py

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -854,7 +854,14 @@ def make_query_from_table(alt_syntax=False):
854854
count_secondary_subqueries(started_cluster, query_id_pure_table_engine_with_type_in_nc, 0, "table engine with storage type in named collection")
855855
count_secondary_subqueries(started_cluster, query_id_pure_table_engine_cluster_with_type_in_nc, 1, "table engine with cluster setting with storage type in named collection")
856856

857-
857+
# Cluster Query with node1 as coordinator
858+
table_function_expr_cluster = get_creation_expression(
859+
storage_type,
860+
TABLE_NAME,
861+
started_cluster,
862+
table_function=True,
863+
run_on_cluster=True,
864+
)
858865
select_remote_cluster = (
859866
instance.query(f"SELECT * FROM remote('node2',{table_function_expr_cluster})")
860867
.strip()

0 commit comments

Comments
 (0)