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

def write(sync_config, records, action = "create")

def write(sync_config, records, action = "create")
  @action = sync_config.stream.action || action
  connection_config = sync_config.destination.connection_specification.with_indifferent_access
  initialize_client(connection_config)
  process_records(records, sync_config.stream)
rescue StandardError => e
  handle_exception("ITERABLE:WRITE:EXCEPTION", "error", e)
end

Instance Methods