"""Loads data from an s3 bucket into a snowflake table."""
COPY_INTO_S3_FROM_JOIN_BY_LABEL = """
    COPY INTO '@{source_snowflake_database}.{source_snowflake_schema}.{s3_stage_name}/{file_name}'
        FROM
            (SELECT src.*,
                IFNULL(TRIM(
                    REPLACE(
                        REPLACE(
                            REPLACE(
                                REPLACE(
                                    REPLACE(
                                        REGEXP_REPLACE(
                                            log.errors, '[\\]\\[]'),
                                        '", "', '; '),
                                    '""', '"'),
                                '";', ';'),
                            '\\\\'),
                        '- "', '- '),
                    '"'), 'COULD NOT PROCESS - SERVER ERROR')
                AS errors
                FROM {source_snowflake_database}.{source_snowflake_schema}.{source_table} as src
             LEFT OUTER JOIN
                {log_snowflake_database}.{log_snowflake_schema}.{track_log_table} as log
             ON src.{product_code_field} = log.PRODUCT_CODE
                AND src.{project_code_field} = log.PROJECT_CODE
                AND src.volume = log.vol_num
                AND src.track_no = log.track_num
                AND session_id = '{session_id}'
                AND ORCHLABELID = {label_id}
             WHERE log.orchard_vendor_id = ORCHLABELID
             ORDER BY src.ROW_NUMBER ASC)
        OVERWRITE = TRUE
        HEADER = TRUE
        SINGLE=TRUE
;
"""
# flake8: noqa