thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-22 23:52:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #60019 from ClickHouse/analyzer-fix-test_sql_user_defined_functions_on_cluster

Browse Source 
Analyzer: Fix test_sql_user_defined_functions_on_cluster
This commit is contained in:
Dmitry Novik 2024-02-16 13:57:55 +01:00 committed by GitHub
commit 757a5b627b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 16 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
tests/analyzer_integration_broken_tests.txt
View File

@ -8,4 +8,3 @@ test_merge_table_over_distributed/test.py::test_global_in
test_merge_table_over_distributed/test.py::test_select_table_name_from_merge_over_distributed
test_passing_max_partitions_to_read_remotely/test.py::test_default_database_on_cluster
test_select_access_rights/test_main.py::test_alias_columns
test_sql_user_defined_functions_on_cluster/test.py::test_sql_user_defined_functions_on_cluster

35
tests/integration/test_sql_user_defined_functions_on_cluster/test.py
View File

@ -1,5 +1,5 @@
import pytest
from helpers.cluster import ClickHouseCluster
from helpers.cluster import ClickHouseCluster, ClickHouseInstance
cluster = ClickHouseCluster(__file__)
ch1 = cluster.add_instance(
@ -24,15 +24,17 @@ def started_cluster():
def test_sql_user_defined_functions_on_cluster():
assert "Unknown function test_function" in ch1.query_and_get_error(
"SELECT test_function(1);"
)
assert "Unknown function test_function" in ch2.query_and_get_error(
"SELECT test_function(1);"
)
assert "Unknown function test_function" in ch3.query_and_get_error(
"SELECT test_function(1);"
)
def check_function_does_not_exist(node: ClickHouseInstance):
error_message = node.query_and_get_error("SELECT test_function(1);")
assert (
"Unknown function test_function" in error_message
or "Function with name 'test_function' does not exists. In scope SELECT test_function(1)"
in error_message
)
check_function_does_not_exist(ch1)
check_function_does_not_exist(ch2)
check_function_does_not_exist(ch3)
ch1.query_with_retry(
"CREATE FUNCTION test_function ON CLUSTER 'cluster' AS x -> x + 1;"
@ -43,12 +45,7 @@ def test_sql_user_defined_functions_on_cluster():
assert ch3.query("SELECT test_function(1);") == "2\n"
ch2.query_with_retry("DROP FUNCTION test_function ON CLUSTER 'cluster'")
assert "Unknown function test_function" in ch1.query_and_get_error(
"SELECT test_function(1);"
)
assert "Unknown function test_function" in ch2.query_and_get_error(
"SELECT test_function(1);"
)
assert "Unknown function test_function" in ch3.query_and_get_error(
"SELECT test_function(1);"
)
check_function_does_not_exist(ch1)
check_function_does_not_exist(ch2)
check_function_does_not_exist(ch3)