class Multiwoven::Integrations::Source::AwsSagemakerModel::Client

def process_response(response)
  data = JSON.parse(response.body.read)
  [RecordMessage.new(data: { response: data }, emitted_at: Time.now.to_i).to_multiwoven_message]
end