Skip to content

Commit 34650e3

Browse files
committed
Fix multiple launch test_executable_udf_names_in_used_functions_column
1 parent f27f944 commit 34650e3

File tree

1 file changed

+3
-2
lines changed
  • tests/integration/test_executable_udf_names_in_used_functions_column

1 file changed

+3
-2
lines changed

tests/integration/test_executable_udf_names_in_used_functions_column/test.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -66,15 +66,16 @@ def check_executable_udf_functions(functions):
6666
assert False
6767
execute_udf = "SELECT {}" if len(functions) == 1 else "SELECT concat({})"
6868
execute_udf = execute_udf.format(','.join(map(lambda function : "{}(1)".format(function), functions)))
69-
node.query(execute_udf)
69+
query_id = uuid.uuid4().hex
70+
node.query(execute_udf, query_id=query_id)
7071
node.query("SYSTEM FLUSH LOGS")
7172

7273
used_functions = set(map(repr, functions))
7374
if len(functions) > 1:
7475
used_functions.add("\'concat\'")
7576

7677
query_result = node.query("SELECT used_functions FROM system.query_log "
77-
"WHERE type = \'QueryFinish\' AND query = \'{}\'".format(execute_udf))
78+
"WHERE type = \'QueryFinish\' AND query_id = \'{}\'".format(query_id))
7879
query_result = set(query_result[1:len(query_result) - 2].split(','))
7980
assert query_result == used_functions
8081

0 commit comments

Comments
 (0)