"""Queries."""
# queries
UPDATE_ROW_STATUS = """
  UPDATE ddex_delivery_to_ingest
  SET status = 'ingest_started'
  WHERE ddex_delivery_to_ingest_id = %s;
"""

"""Select count of rows from a given table.
catalog_ingestion_source_id = 5 is SME_ANALYTICS_PROVIDER
"""
SELECT_ALL_N_ROWS_ORDERED = """
  SELECT ddex_delivery_to_ingest_id, s3_bucket_name, s3_key_name
  FROM ddex_delivery_to_ingest
  WHERE status = 'delivered'
  AND catalog_ingestion_source_id !=5
  ORDER BY received_timestamp
  LIMIT %s;
"""