Activity.where(id: id..(id + 499)).find_in_batches(
      batch_size: 500,
    ) do |activities|
      response =
        Activity.__elasticsearch__.client.bulk index: index,