class Multiwoven::Integrations::Destination::Slack::Client

def process_records(records, stream)
  write_success = 0
  write_failure = 0
  records.each do |record_object|
    process_record(stream, record_object.with_indifferent_access)
    write_success += 1
  rescue StandardError => e
    write_failure += 1
    handle_exception("SLACK:CRM:WRITE:EXCEPTION", "error", e)
  end
  tracking_message(write_success, write_failure)
end