Как устранить ошибку «Ошибка компиляции SQL: объект SNOWPARK_TEMP_STAGE_FLGVIWVUC уже существует». проблема в снежинке?

Попытка исправить два типа ошибок при записи из pandas Dataframe() в таблицы в Snowflake.

1. SNOWPARK_TEMP_FILE_FORMAT_XXXX уже существует
2. SNOWPARK_TEMP_STAGE_XXXX уже существует

Существует также состояние гонки, которое может возникнуть первым, поэтому нам нужно написать try-кроме внутри try-кроме, чтобы решить эту проблему.

Эта проблема наблюдается во всех инструментах, связанных с SNOWPARK, таких как Streamlit в Snowflake, Python-workbook, хранимых процедурах Python и т. д.

# EXAMPLE:
# Modify this fix to your own use accordingly ✅
# Snowflake may patch this BUG in the future.
# This BUG is really annoying. 

import re
from snowflake.snowpark.context import get_active_session
session = get_active_session()

def try_to_write_pd_to_table(my_session, my_df, my_tablename, my_db, my_sch):
    try:
        my_session.write_pandas(my_df, my_tablename, database=f"{my_db}", schema = "{my_sch}", auto_create_table=True, overwrite=True)
    except Exception as e1:
        try:
            tmp_file_format=re.findall('SNOWPARK_TEMP_FILE_FORMAT_[A-Z]{10}', str(e1))
            if (len(tmp_file_format)>0):
                my_session.sql(f'DROP FILE FORMAT IF EXISTS {my_db}.{my_sch}.{tmp_file_format[0]};').collect();
            tmp_stage=re.findall('SNOWPARK_TEMP_STAGE_[A-Z]{10}', str(e1))
            if (len(tmp_stage)>0):
                my_session.sql(f'DROP STAGE IF EXISTS {my_db}.{my_sch}.{tmp_stage[0]};').collect();
            my_session.write_pandas(my_df, my_tablename, database=f"{my_db}", schema = "{my_sch}", auto_create_table=True, overwrite=True)
        except Exception as e2:
            tmp_file_format=re.findall('SNOWPARK_TEMP_FILE_FORMAT_[A-Z]{10}', str(e2))
            if (len(tmp_file_format)>0):
                my_session.sql(f'DROP FILE FORMAT IF EXISTS {my_db}.{my_sch}.{tmp_file_format[0]};').collect();
            tmp_stage=re.findall('SNOWPARK_TEMP_STAGE_[A-Z]{10}', str(e2))
            if (len(tmp_stage)>0):
                my_session.sql(f'DROP STAGE IF EXISTS {my_db}.{my_sch}.{tmp_stage[0]};').collect();
            my_session.write_pandas(my_df, my_tablename, database=f"{my_db}", schema = "{my_sch}", auto_create_table=True, overwrite=True)

try_to_write_pd_to_table(session, df_final, "TEMPTABLE", 'LLM_DATABASE', 'ML_SCHEMA');