class Multiwoven::Integrations::Destination::SalesforceCrm::Client

def write(sync_config, records, _action = "create")
  initialize_client(sync_config[:destination][:connection_specification])
  process_records(records, sync_config[:stream])
rescue StandardError => e
  handle_exception("SALESFORCE:CRM:WRITE:EXCEPTION", "error", e)
end