SELECT_QUERY = """ SELECT ARRAY_SIZE(ARRAY_UNION_AGG(DELETED_FAN_IDS)), MAX(DELETED_AT) AS LAST_DELETED_AT FROM FAN_DATA_DELETION_LOG_DBT WHERE NOT EMAIL_CONFIRM; """ UPDATE_QUERY = """ UPDATE FAN_DATA_DELETION_LOG_DBT SET EMAIL_CONFIRM = TRUE WHERE NOT EMAIL_CONFIRM AND DELETED_AT <= '{last_deleted_at}'; """