"""SQL queries.""" SELECT_UPC_N_ROWS = """ SELECT upc FROM upcs_to_deliver WHERE set_to_complete IS NULL AND failed_set_to_complete IS NULL ORDER BY priority asc LIMIT %s; """ SELECT_UPC_N_ROWS_ASSET_COPY = """ SELECT upc FROM upcs_to_deliver WHERE asset_copy_started IS NOT NULL AND asset_copy_started <= DATE_SUB(NOW(),INTERVAL 4 HOUR) AND set_to_complete IS NULL ORDER BY priority asc LIMIT %s; """ UPDATE_ROW_PRODUCT_SET_TO_COMPLETE = """ UPDATE upcs_to_deliver SET set_to_complete = CURRENT_TIMESTAMP WHERE upc = %s; """ UPDATE_ROW_PRODUCT_SET_TO_NOT_FOUND = """ UPDATE upcs_to_deliver SET set_to_complete = '1971-01-01' WHERE upc = %s; """ UPDATE_ROW_PRODUCT_FAILED_SET_TO_COMPLETE = """ UPDATE upcs_to_deliver SET failed_set_to_complete = CURRENT_TIMESTAMP, error_message = %s WHERE upc = %s; """