"""Error breakdown report for a given ingestion session id."""
ERROR_BREAKDOWN_BY_LABEL = """
COPY INTO '@{source_snowflake_database}.{source_snowflake_schema}.{s3_stage_name}/{file_name}'
    FROM
        (
        SELECT
            TRIM(
                REPLACE(
                    REPLACE(
                        REPLACE(
                            REPLACE(
                                REPLACE(
                                    REGEXP_REPLACE(flat.value, '[\\]\\[]'),
                                '", "', '; '),
                            '""', '"'),
                        '";', ';'),
                    '\\\\'),
                '- "', '- '),
            '\"') AS error,
            count(flat.value) AS error_count from (
            SELECT * FROM {log_snowflake_database}.{log_snowflake_schema}.{track_log_table} AS q
            WHERE session_id = '{session_id}'
            AND ORCHARD_VENDOR_ID = {label_id}) AS tmp,
            LATERAL flatten(input => parse_json(tmp.errors)) flat
        GROUP BY 1
        ORDER BY 1,2
    )
    OVERWRITE = TRUE
    HEADER = TRUE
    SINGLE = TRUE
;
"""
# flake8: noqa