pub async fn process_batch(
    state: &State,
    batch: Vec<UntypedRecord>
) -> Result<()>