(snowflake-demo) @nyck33 โ /workspaces/sfguide-data-engineering-with-snowpark-python/steps/05_fahrenheit_to_celsius_udf (main) $ snow procedure execute -p "orders_update_sp()"
Error executing sql:
use role HOL_ROLE;
use warehouse HOL_WH;
use database HOL_DB;
use schema ANALYTICS;
call orders_update_sp();
002140 (42601): SQL compilation error:
Unknown function ORDERS_UPDATE_SP
โญโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ Traceback (most recent call last) โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฎ
โ /opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowcli/cli/procedure.py:217 in โ
โ procedure_execute โ
โ โ
โ 214 โ โ help="Procedure with inputs. E.g. 'hello(int, string)'. Must exactly match those โ
โ 215 โ ), โ
โ 216 ): โ
โ โฑ 217 โ snowpark_execute("procedure", environment, select) โ
โ 218 โ
โ 219 โ
โ 220 @app.command("describe") โ
โ โ
โ โญโโโโโโโโโโโโโโ locals โโโโโโโโโโโโโโโฎ โ
โ โ environment = 'dev' โ โ
โ โ select = 'orders_update_sp()' โ โ
โ โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ โ
โ โ
โ /opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowcli/cli/snowpark_shared.py:408 โ
โ in snowpark_execute โ
โ โ
โ 405 โ โ โ โ warehouse=env_conf["warehouse"], โ
โ 406 โ โ โ ) โ
โ 407 โ โ elif type == "procedure": โ
โ โฑ 408 โ โ โ results = config.snowflake_connection.executeProcedure( โ
โ 409 โ โ โ โ procedure=select, โ
โ 410 โ โ โ โ database=env_conf["database"], โ
โ 411 โ โ โ โ schema=env_conf["schema"], โ
โ โ
โ โญโโโโโโโโโโโโโโโโโ locals โโโโโโโโโโโโโโโโโโฎ โ
โ โ env_conf = { โ โ
โ โ โ 'database': 'HOL_DB', โ โ
โ โ โ 'schema': 'ANALYTICS', โ โ
โ โ โ 'warehouse': 'HOL_WH', โ โ
โ โ โ 'role': 'HOL_ROLE', โ โ
โ โ โ 'overwrite': True โ โ
โ โ } โ โ
โ โ environment = 'dev' โ โ
โ โ select = 'orders_update_sp()' โ โ
โ โ type = 'procedure' โ โ
โ โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ โ
โ โ
โ /opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowcli/snow_connector.py:179 in โ
โ executeProcedure โ
โ โ
โ 176 โ โ role, โ
โ 177 โ โ warehouse, โ
โ 178 โ ) -> SnowflakeCursor: โ
โ โฑ 179 โ โ return self.runSql( โ
โ 180 โ โ โ "call_procedure", โ
โ 181 โ โ โ { โ
โ 182 โ โ โ โ "database": database, โ
โ โ
โ โญโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ locals โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฎ โ
โ โ database = 'HOL_DB' โ โ
โ โ procedure = 'orders_update_sp()' โ โ
โ โ role = 'HOL_ROLE' โ โ
โ โ schema = 'ANALYTICS' โ โ
โ โ self = <snowcli.snow_connector.SnowflakeConnector object at 0x7f1461860370> โ โ
โ โ warehouse = 'HOL_WH' โ โ
โ โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ โ
โ โ
โ /opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowcli/snow_connector.py:666 in โ
โ runSql โ
โ โ
โ 663 โ โ โ if show_exceptions: โ
โ 664 โ โ โ โ print(f"Error executing sql:\n{sql}") โ
โ 665 โ โ โ โ print(e) โ
โ โฑ 666 โ โ โ raise (e) โ
โ 667 โ โ
โ 668 โ def generate_signature_from_params(self, params: str) -> str: โ
โ 669 โ โ if params == "()": โ
โ โ
โ โญโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ locals โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฎ โ
โ โ command = 'call_procedure' โ โ
โ โ context = { โ โ
โ โ โ 'database': 'HOL_DB', โ โ
โ โ โ 'schema': 'ANALYTICS', โ โ
โ โ โ 'role': 'HOL_ROLE', โ โ
โ โ โ 'warehouse': 'HOL_WH', โ โ
โ โ โ 'procedure': 'orders_update_sp()' โ โ
โ โ } โ โ
โ โ env = <jinja2.environment.Environment object at 0x7f14618601f0> โ โ
โ โ results = <generator object SnowflakeConnection.execute_stream at 0x7f14619a6dc0> โ โ
โ โ self = <snowcli.snow_connector.SnowflakeConnector object at 0x7f1461860370> โ โ
โ โ show_exceptions = True โ โ
โ โ sql = 'use role HOL_ROLE;\nuse warehouse HOL_WH;\nuse database HOL_DB;\nuse โ โ
โ โ schema ANALYTI'+28 โ โ
โ โ template = <Template 'call_procedure.sql'> โ โ
โ โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ โ
โ โ
โ /opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowcli/snow_connector.py:660 in โ
โ runSql โ
โ โ
โ 657 โ โ โ results = self.ctx.execute_stream(StringIO(sql)) โ
โ 658 โ โ โ โ
โ 659 โ โ โ # Return result from last cursor โ
โ โฑ 660 โ โ โ *_, last_result = results โ
โ 661 โ โ โ return last_result โ
โ 662 โ โ except snowflake.connector.errors.ProgrammingError as e: โ
โ 663 โ โ โ if show_exceptions: โ
โ โ
โ โญโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ locals โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฎ โ
โ โ command = 'call_procedure' โ โ
โ โ context = { โ โ
โ โ โ 'database': 'HOL_DB', โ โ
โ โ โ 'schema': 'ANALYTICS', โ โ
โ โ โ 'role': 'HOL_ROLE', โ โ
โ โ โ 'warehouse': 'HOL_WH', โ โ
โ โ โ 'procedure': 'orders_update_sp()' โ โ
โ โ } โ โ
โ โ env = <jinja2.environment.Environment object at 0x7f14618601f0> โ โ
โ โ results = <generator object SnowflakeConnection.execute_stream at 0x7f14619a6dc0> โ โ
โ โ self = <snowcli.snow_connector.SnowflakeConnector object at 0x7f1461860370> โ โ
โ โ show_exceptions = True โ โ
โ โ sql = 'use role HOL_ROLE;\nuse warehouse HOL_WH;\nuse database HOL_DB;\nuse โ โ
โ โ schema ANALYTI'+28 โ โ
โ โ template = <Template 'call_procedure.sql'> โ โ
โ โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ โ
โ โ
โ /opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/connector/connection.py:77 โ
โ 6 in execute_stream โ
โ โ
โ 773 โ โ non_empty_statements = [e for e in split_statements_list if e[0]] โ
โ 774 โ โ for sql, is_put_or_get in non_empty_statements: โ
โ 775 โ โ โ cur = self.cursor(cursor_class=cursor_class) โ
โ โฑ 776 โ โ โ cur.execute(sql, _is_put_get=is_put_or_get, **kwargs) โ
โ 777 โ โ โ yield cur โ
โ 778 โ โ
โ 779 โ def __set_error_attributes(self) -> None: โ
โ โ
โ โญโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ locals โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฎ โ
โ โ cur = <snowflake.connector.cursor.SnowflakeCursor object at โ โ
โ โ 0x7f146154bb20> โ โ
โ โ cursor_class = <class 'snowflake.connector.cursor.SnowflakeCursor'> โ โ
โ โ is_put_or_get = False โ โ
โ โ kwargs = {} โ โ
โ โ non_empty_statements = [ โ โ
โ โ โ ('use role HOL_ROLE;', False), โ โ
โ โ โ ('use warehouse HOL_WH;', False), โ โ
โ โ โ ('use database HOL_DB;', False), โ โ
โ โ โ ('use schema ANALYTICS;', False), โ โ
โ โ โ ('call orders_update_sp();', False) โ โ
โ โ ] โ โ
โ โ remove_comments = False โ โ
โ โ self = <snowflake.connector.connection.SnowflakeConnection object at โ โ
โ โ 0x7f1461860400> โ โ
โ โ split_statements_list = <generator object split_statements at 0x7f14619a75a0> โ โ
โ โ sql = 'call orders_update_sp();' โ โ
โ โ stream = <_io.StringIO object at 0x7f1461506a70> โ โ
โ โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ โ
โ โ
โ /opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/connector/cursor.py:908 in โ
โ execute โ
โ โ
โ 905 โ โ โ โ code == "100072" โ
โ 906 โ โ โ ) # NULL result in a non-nullable column โ
โ 907 โ โ โ error_class = IntegrityError if is_integrity_error else ProgrammingError โ
โ โฑ 908 โ โ โ Error.errorhandler_wrapper(self.connection, self, error_class, errvalue) โ
โ 909 โ โ return self โ
โ 910 โ โ
โ 911 โ def execute_async(self, *args: Any, **kwargs: Any) -> dict[str, Any]: โ
โ โ
โ โญโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ locals โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฎ โ
โ โ _bind_stage = None โ โ
โ โ _describe_only = False โ โ
โ โ _do_reset = True โ โ
โ โ _exec_async = False โ โ
โ โ _force_put_overwrite = False โ โ
โ โ _get_azure_callback = None โ โ
โ โ _get_callback = None โ โ
โ โ _get_callback_output_stream = <_io.TextIOWrapper name='<stdout>' mode='w' โ โ
โ โ encoding='utf-8'> โ โ
โ โ _is_internal = False โ โ
โ โ _is_put_get = False โ โ
โ โ _no_results = False โ โ
โ โ _no_retry = False โ โ
โ โ _put_azure_callback = None โ โ
โ โ _put_callback = None โ โ
โ โ _put_callback_output_stream = <_io.TextIOWrapper name='<stdout>' mode='w' โ โ
โ โ encoding='utf-8'> โ โ
โ โ _raise_put_get_error = True โ โ
โ โ _show_progress_bar = True โ โ
โ โ _skip_upload_on_content_match = False โ โ
โ โ _statement_params = {} โ โ
โ โ code = '002140' โ โ
โ โ command = 'call orders_update_sp();' โ โ
โ โ err = 'SQL compilation error:\nUnknown function ORDERS_UPDATE_SP' โ โ
โ โ error_class = <class 'snowflake.connector.errors.ProgrammingError'> โ โ
โ โ errvalue = { โ โ
โ โ โ 'msg': 'SQL compilation error:\nUnknown function โ โ
โ โ ORDERS_UPDATE_SP', โ โ
โ โ โ 'errno': 2140, โ โ
โ โ โ 'sqlstate': '42601', โ โ
โ โ โ 'sfqid': '01b0ac6f-0001-2a64-0000-000121caa551', โ โ
โ โ โ 'query': 'call orders_update_sp();', โ โ
โ โ โ 'done_format_msg': False โ โ
โ โ } โ โ
โ โ file_stream = None โ โ
โ โ is_integrity_error = False โ โ
โ โ kwargs = { โ โ
โ โ โ 'timeout': None, โ โ
โ โ โ 'statement_params': {}, โ โ
โ โ โ 'is_internal': False, โ โ
โ โ โ 'describe_only': False, โ โ
โ โ โ '_no_results': False, โ โ
โ โ โ '_is_put_get': False, โ โ
โ โ โ '_no_retry': False โ โ
โ โ } โ โ
โ โ m = None โ โ
โ โ num_statements = None โ โ
โ โ params = None โ โ
โ โ query = 'call orders_update_sp();' โ โ
โ โ ret = { โ โ
โ โ โ 'data': { โ โ
โ โ โ โ 'internalError': False, โ โ
โ โ โ โ 'errorCode': '002140', โ โ
โ โ โ โ 'age': 0, โ โ
โ โ โ โ 'sqlState': '42601', โ โ
โ โ โ โ 'queryId': '01b0ac6f-0001-2a64-0000-000121caa551', โ โ
โ โ โ โ 'line': -1, โ โ
โ โ โ โ 'pos': -1, โ โ
โ โ โ โ 'type': 'COMPILATION' โ โ
โ โ โ }, โ โ
โ โ โ 'code': '002140', โ โ
โ โ โ 'message': 'SQL compilation error:\nUnknown function โ โ
โ โ ORDERS_UPDATE_SP', โ โ
โ โ โ 'success': False, โ โ
โ โ โ 'headers': None โ โ
โ โ } โ โ
โ โ self = <snowflake.connector.cursor.SnowflakeCursor object at โ โ
โ โ 0x7f146154bb20> โ โ
โ โ timeout = None โ โ
โ โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ โ
โ โ
โ /opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/connector/errors.py:290 in โ
โ errorhandler_wrapper โ
โ โ
โ 287 โ โ โ exception to the first handler in that order. โ
โ 288 โ โ """ โ
โ 289 โ โ โ
โ โฑ 290 โ โ handed_over = Error.hand_to_other_handler( โ
โ 291 โ โ โ connection, โ
โ 292 โ โ โ cursor, โ
โ 293 โ โ โ error_class, โ
โ โ
โ โญโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ locals โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฎ โ
โ โ connection = <snowflake.connector.connection.SnowflakeConnection object at 0x7f1461860400> โ โ
โ โ cursor = <snowflake.connector.cursor.SnowflakeCursor object at 0x7f146154bb20> โ โ
โ โ error_class = <class 'snowflake.connector.errors.ProgrammingError'> โ โ
โ โ error_value = { โ โ
โ โ โ 'msg': 'SQL compilation error:\nUnknown function ORDERS_UPDATE_SP', โ โ
โ โ โ 'errno': 2140, โ โ
โ โ โ 'sqlstate': '42601', โ โ
โ โ โ 'sfqid': '01b0ac6f-0001-2a64-0000-000121caa551', โ โ
โ โ โ 'query': 'call orders_update_sp();', โ โ
โ โ โ 'done_format_msg': False โ โ
โ โ } โ โ
โ โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ โ
โ โ
โ /opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/connector/errors.py:345 in โ
โ hand_to_other_handler โ
โ โ
โ 342 โ โ โ connection.messages.append((error_class, error_value)) โ
โ 343 โ โ if cursor is not None: โ
โ 344 โ โ โ cursor.messages.append((error_class, error_value)) โ
โ โฑ 345 โ โ โ cursor.errorhandler(connection, cursor, error_class, error_value) โ
โ 346 โ โ โ return True โ
โ 347 โ โ elif connection is not None: โ
โ 348 โ โ โ connection.errorhandler(connection, cursor, error_class, error_value) โ
โ โ
โ โญโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ locals โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฎ โ
โ โ connection = <snowflake.connector.connection.SnowflakeConnection object at 0x7f1461860400> โ โ
โ โ cursor = <snowflake.connector.cursor.SnowflakeCursor object at 0x7f146154bb20> โ โ
โ โ error_class = <class 'snowflake.connector.errors.ProgrammingError'> โ โ
โ โ error_value = { โ โ
โ โ โ 'msg': 'SQL compilation error:\nUnknown function ORDERS_UPDATE_SP', โ โ
โ โ โ 'errno': 2140, โ โ
โ โ โ 'sqlstate': '42601', โ โ
โ โ โ 'sfqid': '01b0ac6f-0001-2a64-0000-000121caa551', โ โ
โ โ โ 'query': 'call orders_update_sp();', โ โ
โ โ โ 'done_format_msg': False โ โ
โ โ } โ โ
โ โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ โ
โ โ
โ /opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/connector/errors.py:221 in โ
โ default_errorhandler โ
โ โ
โ 218 โ โ """ โ
โ 219 โ โ errno = error_value.get("errno") โ
โ 220 โ โ done_format_msg = error_value.get("done_format_msg") โ
โ โฑ 221 โ โ raise error_class( โ
โ 222 โ โ โ msg=error_value.get("msg"), โ
โ 223 โ โ โ errno=None if errno is None else int(errno), โ
โ 224 โ โ โ sqlstate=error_value.get("sqlstate"), โ
โ โ
โ โญโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ locals โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฎ โ
โ โ connection = <snowflake.connector.connection.SnowflakeConnection object at โ โ
โ โ 0x7f1461860400> โ โ
โ โ cursor = <snowflake.connector.cursor.SnowflakeCursor object at 0x7f146154bb20> โ โ
โ โ done_format_msg = False โ โ
โ โ errno = 2140 โ โ
โ โ error_class = <class 'snowflake.connector.errors.ProgrammingError'> โ โ
โ โ error_value = { โ โ
โ โ โ 'msg': 'SQL compilation error:\nUnknown function ORDERS_UPDATE_SP', โ โ
โ โ โ 'errno': 2140, โ โ
โ โ โ 'sqlstate': '42601', โ โ
โ โ โ 'sfqid': '01b0ac6f-0001-2a64-0000-000121caa551', โ โ
โ โ โ 'query': 'call orders_update_sp();', โ โ
โ โ โ 'done_format_msg': False โ โ
โ โ } โ โ
โ โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ โ
โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ
ProgrammingError: 002140 (42601): SQL compilation error:
Unknown function ORDERS_UPDATE_SP
(snowflake-demo) @nyck33 โ /workspaces/sfguide-data-engineering-with-snowpark-python/steps/05_fahrenheit_to_celsius_udf (main) $ cd ..
(snowflake-demo) @nyck33 โ /workspaces/sfguide-data-engineering-with-snowpark-python/steps (main) $ ls
01_setup_snowflake.sql 04_create_pos_view.py 07_daily_city_metrics_update_sp 10_deploy_via_cicd.sql
02_load_raw.py 05_fahrenheit_to_celsius_udf 08_orchestrate_jobs.sql 11_teardown.sql
03_load_weather.sql 06_orders_update_sp 09_process_incrementally.sql
(snowflake-demo) @nyck33 โ /workspaces/sfguide-data-engineering-with-snowpark-python/steps (main) $ cd 06_orders_update_sp
(snowflake-demo) @nyck33 โ /workspaces/sfguide-data-engineering-with-snowpark-python/steps/06_orders_update_sp (main) $ snow procedure execute -p "orders_update_sp()"
Error executing sql:
use role HOL_ROLE;
use warehouse HOL_WH;
use database HOL_DB;
use schema HARMONIZED;
call orders_update_sp();
100357 (P0000): Python Interpreter Error:
Traceback (most recent call last):
File "/home/udf/18991632/app.zip/app.py", line 47, in main
create_orders_table(session)
File "/home/udf/18991632/app.zip/app.py", line 21, in create_orders_table
_ = session.sql("CREATE TABLE HARMONIZED.ORDERS LIKE HARMONIZED.POS_FLATTENED_V").collect()
File "/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowflake/snowpark/_internal/telemetry.py", line 139, in wrap
result = func(*args, **kwargs)
File "/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowflake/snowpark/dataframe.py", line 586, in collect
return self._internal_collect_with_tag_no_telemetry(
File "/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowflake/snowpark/dataframe.py", line 633, in _internal_collect_with_tag_no_telemetry
return self._session._conn.execute(
File "/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowflake/snowpark/_internal/server_connection.py", line 451, in execute
result_set, result_meta = self.get_result_set(
File "/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowflake/snowpark/_internal/analyzer/snowflake_plan.py", line 181, in wrap
raise ne.with_traceback(tb) from None
File "/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowflake/snowpark/_internal/analyzer/snowflake_plan.py", line 111, in wrap
return func(*args, **kwargs)
File "/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowflake/snowpark/_internal/server_connection.py", line 552, in get_result_set
result = self.run_query(
File "/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowflake/snowpark/_internal/server_connection.py", line 102, in wrap
raise ex
File "/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowflake/snowpark/_internal/server_connection.py", line 96, in wrap
return func(*args, **kwargs)
File "/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowflake/snowpark/_internal/server_connection.py", line 366, in run_query
raise ex
File "/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowflake/snowpark/_internal/server_connection.py", line 347, in run_query
results_cursor = self._cursor.execute(query, params=params, **kwargs)
File "/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowflake/connector/cursor.py", line 867, in execute
Error.errorhandler_wrapper(
File "/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowflake/connector/errors.py", line 232, in errorhandler_wrapper
handed_over = Error.hand_to_other_handler(
File "/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowflake/connector/errors.py", line 287, in hand_to_other_handler
cursor.errorhandler(connection, cursor, error_class, error_value)
File "/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowflake/connector/errors.py", line 165, in default_errorhandler
raise error_class(
snowflake.snowpark.exceptions.SnowparkSQLException: (1304): 01b0ac6f-0001-2a64-0000-000121caa569: 002003 (42S02): SQL compilation error:
Object 'HOL_DB.HARMONIZED.POS_FLATTENED_V' does not exist or not authorized.
in function ORDERS_UPDATE_SP with handler app.main
โญโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ Traceback (most recent call last) โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฎ
โ /opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowcli/cli/procedure.py:217 in โ
โ procedure_execute โ
โ โ
โ 214 โ โ help="Procedure with inputs. E.g. 'hello(int, string)'. Must exactly match those โ
โ 215 โ ), โ
โ 216 ): โ
โ โฑ 217 โ snowpark_execute("procedure", environment, select) โ
โ 218 โ
โ 219 โ
โ 220 @app.command("describe") โ
โ โ
โ โญโโโโโโโโโโโโโโ locals โโโโโโโโโโโโโโโฎ โ
โ โ environment = 'dev' โ โ
โ โ select = 'orders_update_sp()' โ โ
โ โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ โ
โ โ
โ /opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowcli/cli/snowpark_shared.py:408 โ
โ in snowpark_execute โ
โ โ
โ 405 โ โ โ โ warehouse=env_conf["warehouse"], โ
โ 406 โ โ โ ) โ
โ 407 โ โ elif type == "procedure": โ
โ โฑ 408 โ โ โ results = config.snowflake_connection.executeProcedure( โ
โ 409 โ โ โ โ procedure=select, โ
โ 410 โ โ โ โ database=env_conf["database"], โ
โ 411 โ โ โ โ schema=env_conf["schema"], โ
โ โ
โ โญโโโโโโโโโโโโโโโโโ locals โโโโโโโโโโโโโโโโโโโฎ โ
โ โ env_conf = { โ โ
โ โ โ 'database': 'HOL_DB', โ โ
โ โ โ 'schema': 'HARMONIZED', โ โ
โ โ โ 'warehouse': 'HOL_WH', โ โ
โ โ โ 'role': 'HOL_ROLE', โ โ
โ โ โ 'overwrite': True โ โ
โ โ } โ โ
โ โ environment = 'dev' โ โ
โ โ select = 'orders_update_sp()' โ โ
โ โ type = 'procedure' โ โ
โ โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ โ
โ โ
โ /opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowcli/snow_connector.py:179 in โ
โ executeProcedure โ
โ โ
โ 176 โ โ role, โ
โ 177 โ โ warehouse, โ
โ 178 โ ) -> SnowflakeCursor: โ
โ โฑ 179 โ โ return self.runSql( โ
โ 180 โ โ โ "call_procedure", โ
โ 181 โ โ โ { โ
โ 182 โ โ โ โ "database": database, โ
โ โ
โ โญโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ locals โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฎ โ
โ โ database = 'HOL_DB' โ โ
โ โ procedure = 'orders_update_sp()' โ โ
โ โ role = 'HOL_ROLE' โ โ
โ โ schema = 'HARMONIZED' โ โ
โ โ self = <snowcli.snow_connector.SnowflakeConnector object at 0x7fc9fa898370> โ โ
โ โ warehouse = 'HOL_WH' โ โ
โ โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ โ
โ โ
โ /opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowcli/snow_connector.py:666 in โ
โ runSql โ
โ โ
โ 663 โ โ โ if show_exceptions: โ
โ 664 โ โ โ โ print(f"Error executing sql:\n{sql}") โ
โ 665 โ โ โ โ print(e) โ
โ โฑ 666 โ โ โ raise (e) โ
โ 667 โ โ
โ 668 โ def generate_signature_from_params(self, params: str) -> str: โ
โ 669 โ โ if params == "()": โ
โ โ
โ โญโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ locals โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฎ โ
โ โ command = 'call_procedure' โ โ
โ โ context = { โ โ
โ โ โ 'database': 'HOL_DB', โ โ
โ โ โ 'schema': 'HARMONIZED', โ โ
โ โ โ 'role': 'HOL_ROLE', โ โ
โ โ โ 'warehouse': 'HOL_WH', โ โ
โ โ โ 'procedure': 'orders_update_sp()' โ โ
โ โ } โ โ
โ โ env = <jinja2.environment.Environment object at 0x7fc9fa8981f0> โ โ
โ โ results = <generator object SnowflakeConnection.execute_stream at 0x7fc9fa7e2dc0> โ โ
โ โ self = <snowcli.snow_connector.SnowflakeConnector object at 0x7fc9fa898370> โ โ
โ โ show_exceptions = True โ โ
โ โ sql = 'use role HOL_ROLE;\nuse warehouse HOL_WH;\nuse database HOL_DB;\nuse โ โ
โ โ schema HARMONI'+29 โ โ
โ โ template = <Template 'call_procedure.sql'> โ โ
โ โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ โ
โ โ
โ /opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowcli/snow_connector.py:660 in โ
โ runSql โ
โ โ
โ 657 โ โ โ results = self.ctx.execute_stream(StringIO(sql)) โ
โ 658 โ โ โ โ
โ 659 โ โ โ # Return result from last cursor โ
โ โฑ 660 โ โ โ *_, last_result = results โ
โ 661 โ โ โ return last_result โ
โ 662 โ โ except snowflake.connector.errors.ProgrammingError as e: โ
โ 663 โ โ โ if show_exceptions: โ
โ โ
โ โญโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ locals โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฎ โ
โ โ command = 'call_procedure' โ โ
โ โ context = { โ โ
โ โ โ 'database': 'HOL_DB', โ โ
โ โ โ 'schema': 'HARMONIZED', โ โ
โ โ โ 'role': 'HOL_ROLE', โ โ
โ โ โ 'warehouse': 'HOL_WH', โ โ
โ โ โ 'procedure': 'orders_update_sp()' โ โ
โ โ } โ โ
โ โ env = <jinja2.environment.Environment object at 0x7fc9fa8981f0> โ โ
โ โ results = <generator object SnowflakeConnection.execute_stream at 0x7fc9fa7e2dc0> โ โ
โ โ self = <snowcli.snow_connector.SnowflakeConnector object at 0x7fc9fa898370> โ โ
โ โ show_exceptions = True โ โ
โ โ sql = 'use role HOL_ROLE;\nuse warehouse HOL_WH;\nuse database HOL_DB;\nuse โ โ
โ โ schema HARMONI'+29 โ โ
โ โ template = <Template 'call_procedure.sql'> โ โ
โ โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ โ
โ โ
โ /opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/connector/connection.py:77 โ
โ 6 in execute_stream โ
โ โ
โ 773 โ โ non_empty_statements = [e for e in split_statements_list if e[0]] โ
โ 774 โ โ for sql, is_put_or_get in non_empty_statements: โ
โ 775 โ โ โ cur = self.cursor(cursor_class=cursor_class) โ
โ โฑ 776 โ โ โ cur.execute(sql, _is_put_get=is_put_or_get, **kwargs) โ
โ 777 โ โ โ yield cur โ
โ 778 โ โ
โ 779 โ def __set_error_attributes(self) -> None: โ
โ โ
โ โญโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ locals โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฎ โ
โ โ cur = <snowflake.connector.cursor.SnowflakeCursor object at โ โ
โ โ 0x7fc9fa3a3b20> โ โ
โ โ cursor_class = <class 'snowflake.connector.cursor.SnowflakeCursor'> โ โ
โ โ is_put_or_get = False โ โ
โ โ kwargs = {} โ โ
โ โ non_empty_statements = [ โ โ
โ โ โ ('use role HOL_ROLE;', False), โ โ
โ โ โ ('use warehouse HOL_WH;', False), โ โ
โ โ โ ('use database HOL_DB;', False), โ โ
โ โ โ ('use schema HARMONIZED;', False), โ โ
โ โ โ ('call orders_update_sp();', False) โ โ
โ โ ] โ โ
โ โ remove_comments = False โ โ
โ โ self = <snowflake.connector.connection.SnowflakeConnection object at โ โ
โ โ 0x7fc9fa898400> โ โ
โ โ split_statements_list = <generator object split_statements at 0x7fc9fa7e35a0> โ โ
โ โ sql = 'call orders_update_sp();' โ โ
โ โ stream = <_io.StringIO object at 0x7fc9fa35e8c0> โ โ
โ โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ โ
โ โ
โ /opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/connector/cursor.py:908 in โ
โ execute โ
โ โ
โ 905 โ โ โ โ code == "100072" โ
โ 906 โ โ โ ) # NULL result in a non-nullable column โ
โ 907 โ โ โ error_class = IntegrityError if is_integrity_error else ProgrammingError โ
โ โฑ 908 โ โ โ Error.errorhandler_wrapper(self.connection, self, error_class, errvalue) โ
โ 909 โ โ return self โ
โ 910 โ โ
โ 911 โ def execute_async(self, *args: Any, **kwargs: Any) -> dict[str, Any]: โ
โ โ
โ โญโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ locals โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฎ โ
โ โ _bind_stage = None โ โ
โ โ _describe_only = False โ โ
โ โ _do_reset = True โ โ
โ โ _exec_async = False โ โ
โ โ _force_put_overwrite = False โ โ
โ โ _get_azure_callback = None โ โ
โ โ _get_callback = None โ โ
โ โ _get_callback_output_stream = <_io.TextIOWrapper name='<stdout>' mode='w' โ โ
โ โ encoding='utf-8'> โ โ
โ โ _is_internal = False โ โ
โ โ _is_put_get = False โ โ
โ โ _no_results = False โ โ
โ โ _no_retry = False โ โ
โ โ _put_azure_callback = None โ โ
โ โ _put_callback = None โ โ
โ โ _put_callback_output_stream = <_io.TextIOWrapper name='<stdout>' mode='w' โ โ
โ โ encoding='utf-8'> โ โ
โ โ _raise_put_get_error = True โ โ
โ โ _show_progress_bar = True โ โ
โ โ _skip_upload_on_content_match = False โ โ
โ โ _statement_params = {} โ โ
โ โ code = '100357' โ โ
โ โ command = 'call orders_update_sp();' โ โ
โ โ err = 'Python Interpreter Error:\nTraceback (most recent call โ โ
โ โ last):\n File "/home/udf/1'+3969 โ โ
โ โ error_class = <class 'snowflake.connector.errors.ProgrammingError'> โ โ
โ โ errvalue = { โ โ
โ โ โ 'msg': 'Python Interpreter Error:\nTraceback (most โ โ
โ โ recent call last):\n File "/home/udf/1'+3969, โ โ
โ โ โ 'errno': 100357, โ โ
โ โ โ 'sqlstate': 'P0000', โ โ
โ โ โ 'sfqid': '01b0ac6f-0001-2a64-0000-000121caa55d', โ โ
โ โ โ 'query': 'call orders_update_sp();', โ โ
โ โ โ 'done_format_msg': False โ โ
โ โ } โ โ
โ โ file_stream = None โ โ
โ โ is_integrity_error = False โ โ
โ โ kwargs = { โ โ
โ โ โ 'timeout': None, โ โ
โ โ โ 'statement_params': {}, โ โ
โ โ โ 'is_internal': False, โ โ
โ โ โ 'describe_only': False, โ โ
โ โ โ '_no_results': False, โ โ
โ โ โ '_is_put_get': False, โ โ
โ โ โ '_no_retry': False โ โ
โ โ } โ โ
โ โ m = None โ โ
โ โ num_statements = None โ โ
โ โ params = None โ โ
โ โ query = 'call orders_update_sp();' โ โ
โ โ ret = { โ โ
โ โ โ 'data': { โ โ
โ โ โ โ 'internalError': False, โ โ
โ โ โ โ 'errorCode': '100357', โ โ
โ โ โ โ 'age': 0, โ โ
โ โ โ โ 'sqlState': 'P0000', โ โ
โ โ โ โ 'queryId': '01b0ac6f-0001-2a64-0000-000121caa55d' โ โ
โ โ โ }, โ โ
โ โ โ 'code': '100357', โ โ
โ โ โ 'message': 'Python Interpreter Error:\nTraceback (most โ โ
โ โ recent call last):\n File "/home/udf/1'+3969, โ โ
โ โ โ 'success': False, โ โ
โ โ โ 'headers': None โ โ
โ โ } โ โ
โ โ self = <snowflake.connector.cursor.SnowflakeCursor object at โ โ
โ โ 0x7fc9fa3a3b20> โ โ
โ โ timeout = None โ โ
โ โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ โ
โ โ
โ /opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/connector/errors.py:290 in โ
โ errorhandler_wrapper โ
โ โ
โ 287 โ โ โ exception to the first handler in that order. โ
โ 288 โ โ """ โ
โ 289 โ โ โ
โ โฑ 290 โ โ handed_over = Error.hand_to_other_handler( โ
โ 291 โ โ โ connection, โ
โ 292 โ โ โ cursor, โ
โ 293 โ โ โ error_class, โ
โ โ
โ โญโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ locals โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฎ โ
โ โ connection = <snowflake.connector.connection.SnowflakeConnection object at 0x7fc9fa898400> โ โ
โ โ cursor = <snowflake.connector.cursor.SnowflakeCursor object at 0x7fc9fa3a3b20> โ โ
โ โ error_class = <class 'snowflake.connector.errors.ProgrammingError'> โ โ
โ โ error_value = { โ โ
โ โ โ 'msg': 'Python Interpreter Error:\nTraceback (most recent call last):\n โ โ
โ โ File "/home/udf/1'+3969, โ โ
โ โ โ 'errno': 100357, โ โ
โ โ โ 'sqlstate': 'P0000', โ โ
โ โ โ 'sfqid': '01b0ac6f-0001-2a64-0000-000121caa55d', โ โ
โ โ โ 'query': 'call orders_update_sp();', โ โ
โ โ โ 'done_format_msg': False โ โ
โ โ } โ โ
โ โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ โ
โ โ
โ /opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/connector/errors.py:345 in โ
โ hand_to_other_handler โ
โ โ
โ 342 โ โ โ connection.messages.append((error_class, error_value)) โ
โ 343 โ โ if cursor is not None: โ
โ 344 โ โ โ cursor.messages.append((error_class, error_value)) โ
โ โฑ 345 โ โ โ cursor.errorhandler(connection, cursor, error_class, error_value) โ
โ 346 โ โ โ return True โ
โ 347 โ โ elif connection is not None: โ
โ 348 โ โ โ connection.errorhandler(connection, cursor, error_class, error_value) โ
โ โ
โ โญโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ locals โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฎ โ
โ โ connection = <snowflake.connector.connection.SnowflakeConnection object at 0x7fc9fa898400> โ โ
โ โ cursor = <snowflake.connector.cursor.SnowflakeCursor object at 0x7fc9fa3a3b20> โ โ
โ โ error_class = <class 'snowflake.connector.errors.ProgrammingError'> โ โ
โ โ error_value = { โ โ
โ โ โ 'msg': 'Python Interpreter Error:\nTraceback (most recent call last):\n โ โ
โ โ File "/home/udf/1'+3969, โ โ
โ โ โ 'errno': 100357, โ โ
โ โ โ 'sqlstate': 'P0000', โ โ
โ โ โ 'sfqid': '01b0ac6f-0001-2a64-0000-000121caa55d', โ โ
โ โ โ 'query': 'call orders_update_sp();', โ โ
โ โ โ 'done_format_msg': False โ โ
โ โ } โ โ
โ โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ โ
โ โ
โ /opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/connector/errors.py:221 in โ
โ default_errorhandler โ
โ โ
โ 218 โ โ """ โ
โ 219 โ โ errno = error_value.get("errno") โ
โ 220 โ โ done_format_msg = error_value.get("done_format_msg") โ
โ โฑ 221 โ โ raise error_class( โ
โ 222 โ โ โ msg=error_value.get("msg"), โ
โ 223 โ โ โ errno=None if errno is None else int(errno), โ
โ 224 โ โ โ sqlstate=error_value.get("sqlstate"), โ
โ โ
โ โญโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ locals โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฎ โ
โ โ connection = <snowflake.connector.connection.SnowflakeConnection object at โ โ
โ โ 0x7fc9fa898400> โ โ
โ โ cursor = <snowflake.connector.cursor.SnowflakeCursor object at 0x7fc9fa3a3b20> โ โ
โ โ done_format_msg = False โ โ
โ โ errno = 100357 โ โ
โ โ error_class = <class 'snowflake.connector.errors.ProgrammingError'> โ โ
โ โ error_value = { โ โ
โ โ โ 'msg': 'Python Interpreter Error:\nTraceback (most recent call โ โ
โ โ last):\n File "/home/udf/1'+3969, โ โ
โ โ โ 'errno': 100357, โ โ
โ โ โ 'sqlstate': 'P0000', โ โ
โ โ โ 'sfqid': '01b0ac6f-0001-2a64-0000-000121caa55d', โ โ
โ โ โ 'query': 'call orders_update_sp();', โ โ
โ โ โ 'done_format_msg': False โ โ
โ โ } โ โ
โ โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ โ
โฐโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฏ
ProgrammingError: 100357 (P0000): Python Interpreter Error:
Traceback (most recent call last):
File "/home/udf/18991632/app.zip/app.py", line 47, in main
create_orders_table(session)
File "/home/udf/18991632/app.zip/app.py", line 21, in create_orders_table
_ = session.sql("CREATE TABLE HARMONIZED.ORDERS LIKE HARMONIZED.POS_FLATTENED_V").collect()
File
"/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowf
lake/snowpark/_internal/telemetry.py", line 139, in wrap
result = func(*args, **kwargs)
File
"/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowf
lake/snowpark/dataframe.py", line 586, in collect
return self._internal_collect_with_tag_no_telemetry(
File
"/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowf
lake/snowpark/dataframe.py", line 633, in _internal_collect_with_tag_no_telemetry
return self._session._conn.execute(
File
"/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowf
lake/snowpark/_internal/server_connection.py", line 451, in execute
result_set, result_meta = self.get_result_set(
File
"/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowf
lake/snowpark/_internal/analyzer/snowflake_plan.py", line 181, in wrap
raise ne.with_traceback(tb) from None
File
"/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowf
lake/snowpark/_internal/analyzer/snowflake_plan.py", line 111, in wrap
return func(*args, **kwargs)
File
"/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowf
lake/snowpark/_internal/server_connection.py", line 552, in get_result_set
result = self.run_query(
File
"/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowf
lake/snowpark/_internal/server_connection.py", line 102, in wrap
raise ex
File
"/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowf
lake/snowpark/_internal/server_connection.py", line 96, in wrap
return func(*args, **kwargs)
File
"/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowf
lake/snowpark/_internal/server_connection.py", line 366, in run_query
raise ex
File
"/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowf
lake/snowpark/_internal/server_connection.py", line 347, in run_query
results_cursor = self._cursor.execute(query, params=params, **kwargs)
File
"/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowf
lake/connector/cursor.py", line 867, in execute
Error.errorhandler_wrapper(
File
"/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowf
lake/connector/errors.py", line 232, in errorhandler_wrapper
handed_over = Error.hand_to_other_handler(
File
"/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowf
lake/connector/errors.py", line 287, in hand_to_other_handler
cursor.errorhandler(connection, cursor, error_class, error_value)
File
"/usr/lib/python_udf/1ffa8b97b173d13a75954c71a802ce7a006594e2ba885538acd15cbc79361324/lib/python3.8/site-packages/snowf
lake/connector/errors.py", line 165, in default_errorhandler
raise error_class(
snowflake.snowpark.exceptions.SnowparkSQLException: (1304): 01b0ac6f-0001-2a64-0000-000121caa569: 002003 (42S02): SQL
compilation error:
Object 'HOL_DB.HARMONIZED.POS_FLATTENED_V' does not exist or not authorized.
in function ORDERS_UPDATE_SP with handler app.main
(snowflake-demo) @nyck33 โ /workspaces/sfguide-data-engineering-with-snowpark-python/steps/06_orders_update_sp (main) $ python app.py
Traceback (most recent call last):
File "/workspaces/sfguide-data-engineering-with-snowpark-python/steps/06_orders_update_sp/app.py", line 72, in <module>
print(main(session)) # type: ignore
File "/workspaces/sfguide-data-engineering-with-snowpark-python/steps/06_orders_update_sp/app.py", line 51, in main
merge_order_updates(session)
File "/workspaces/sfguide-data-engineering-with-snowpark-python/steps/06_orders_update_sp/app.py", line 39, in merge_order_updates
target.merge(source, target['ORDER_DETAIL_ID'] == source['ORDER_DETAIL_ID'], \
File "/opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/snowpark/table.py", line 641, in merge
result = new_df._internal_collect_with_tag(
File "/opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/snowpark/_internal/telemetry.py", line 139, in wrap
result = func(*args, **kwargs)
File "/opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/snowpark/dataframe.py", line 633, in _internal_collect_with_tag_no_telemetry
return self._session._conn.execute(
File "/opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/snowpark/_internal/server_connection.py", line 451, in execute
result_set, result_meta = self.get_result_set(
File "/opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/snowpark/_internal/analyzer/snowflake_plan.py", line 181, in wrap
raise ne.with_traceback(tb) from None
File "/opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/snowpark/_internal/analyzer/snowflake_plan.py", line 111, in wrap
return func(*args, **kwargs)
File "/opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/snowpark/_internal/server_connection.py", line 552, in get_result_set
result = self.run_query(
File "/opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/snowpark/_internal/server_connection.py", line 102, in wrap
raise ex
File "/opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/snowpark/_internal/server_connection.py", line 96, in wrap
return func(*args, **kwargs)
File "/opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/snowpark/_internal/server_connection.py", line 366, in run_query
raise ex
File "/opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/snowpark/_internal/server_connection.py", line 347, in run_query
results_cursor = self._cursor.execute(query, params=params, **kwargs)
File "/opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/connector/cursor.py", line 908, in execute
Error.errorhandler_wrapper(self.connection, self, error_class, errvalue)
File "/opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/connector/errors.py", line 290, in errorhandler_wrapper
handed_over = Error.hand_to_other_handler(
File "/opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/connector/errors.py", line 345, in hand_to_other_handler
cursor.errorhandler(connection, cursor, error_class, error_value)
File "/opt/conda/envs/snowflake-demo/lib/python3.10/site-packages/snowflake/connector/errors.py", line 221, in default_errorhandler
raise error_class(
snowflake.snowpark.exceptions.SnowparkSQLException: (1304): 100090 (42P18): Duplicate row detected during DML action
Row Values: [437552392, 61, 1611566566000000000, 18652, 844859897, 0, "Freezing Point", "Ice Cream", "New York City", "New York", "United States", 1, 49, "Bruce", "Kent", 15162, 11, "Sugar Cone", 1, 60000, 60000, 520000, NULL, NULL, 520000, 1701311173737000000]
(snowflake-demo) @nyck33 โ /workspaces/sfguide-data-engineering-with-snowpark-python/steps/06_orders_update_sp (main) $ Then on Snowsight: