# flake8: noqa
import config

UPDATE_INGESTION_STATE = f"""
UPDATE GRPS_INGESTOR.{config.ENVIRONMENT}.GRPS_PRODUCTS_TO_INGEST
SET status = %(status)s, 
    last_updated = CURRENT_TIMESTAMP()
WHERE grps_ingestion_id = %(grps_ingestion_id)s
"""

UPDATE_GRPS_INGESTER_EXTENDED = f"""
INSERT INTO GRPS_INGESTOR.{config.ENVIRONMENT}.GRPS_INGESTION_EXTENDED_INFO (
	grps_ingestion_id,
	isrcs,
	error,
	deleted_tracks
)
select %(grps_ingestion_id)s, ARRAY_CONSTRUCT(%(isrcs)s), %(error)s, ARRAY_CONSTRUCT(%(deleted_tracks)s)
"""