# flake8: noqa
import config
from common.constants.grps_ingestion_status import SCHEDULED

GET_UPC_TO_PROCESS = f"""
select upc, grps_ingestion_id, prod_no from GRPS_INGESTOR.{config.ENVIRONMENT}.GRPS_PRODUCTS_TO_INGEST
where status = '{SCHEDULED}'
order by release_date desc   
limit %(nr_ingests)s 
; 
"""

UPDATE_GRPS_INGESTION = f"""
update GRPS_INGESTOR.{config.ENVIRONMENT}.GRPS_PRODUCTS_TO_INGEST
set status = %(status)s,
    sfn_url= %(sfn_url)s
where GRPS_INGESTION_ID = %(grps_ingestion_id)s
"""