|
3 | 3 | import textwrap
|
4 | 4 | from typing import Any, Dict, List, Optional, Tuple
|
5 | 5 |
|
6 |
| -from packaging import version |
7 |
| - |
8 | 6 | from snowflake import snowpark
|
9 | 7 | from snowflake.ml._internal.utils import (
|
10 | 8 | identifier,
|
11 | 9 | query_result_checker,
|
12 |
| - snowflake_env, |
13 | 10 | sql_identifier,
|
14 | 11 | )
|
15 | 12 | from snowflake.ml.model._client.sql import _base
|
@@ -120,21 +117,12 @@ def invoke_function_method(
|
120 | 117 | args_sql_list.append(input_arg_value)
|
121 | 118 | args_sql = ", ".join(args_sql_list)
|
122 | 119 |
|
123 |
| - if snowflake_env.get_current_snowflake_version( |
124 |
| - self._session, statement_params=statement_params |
125 |
| - ) >= version.parse("8.39.0"): |
126 |
| - fully_qualified_service_name = self.fully_qualified_object_name( |
127 |
| - actual_database_name, actual_schema_name, service_name |
128 |
| - ) |
129 |
| - fully_qualified_function_name = f"{fully_qualified_service_name}!{method_name.identifier()}" |
130 |
| - |
131 |
| - else: |
132 |
| - function_name = identifier.concat_names([service_name.identifier(), "_", method_name.identifier()]) |
133 |
| - fully_qualified_function_name = identifier.get_schema_level_object_identifier( |
134 |
| - actual_database_name.identifier(), |
135 |
| - actual_schema_name.identifier(), |
136 |
| - function_name, |
137 |
| - ) |
| 120 | + function_name = identifier.concat_names([service_name.identifier(), "_", method_name.identifier()]) |
| 121 | + fully_qualified_function_name = identifier.get_schema_level_object_identifier( |
| 122 | + actual_database_name.identifier(), |
| 123 | + actual_schema_name.identifier(), |
| 124 | + function_name, |
| 125 | + ) |
138 | 126 |
|
139 | 127 | sql = textwrap.dedent(
|
140 | 128 | f"""{with_sql}
|
|
0 commit comments