class Multiwoven::Integrations::Destination::SalesforceConsumerGoodsCloud::Client

def send_data_to_salesforce(stream_name, record = {})
  method_name = "upsert!"
  args = [stream_name, "Id", record]
  @logger.debug("sync_id: #{@sync_config.sync_id}, sync_run_id: #{@sync_config.sync_run_id}, record: #{record}")
  @client.send(method_name, *args)
end