class Multiwoven::Integrations::Destination::Iterable::Client

def process_records(records, stream)
  log_message_array = []
  write_success = 0
  write_failure = 0
  records.each do |record_object|
    record = extract_data(record_object, stream.json_schema[:properties])
    request, response = *process_stream(record, stream)
    if response.success?
      write_success += 1
    else
      write_failure += 1
    end
    log_message_array << log_request_response("info", request, response.body)
  rescue StandardError => e
    handle_exception("ITERABLE:WRITE:EXCEPTION", "error", e)
    write_failure += 1
    log_message_array << log_request_response("error", request, e.message)
  end
  tracking_message(write_success, write_failure, log_message_array)
end