class Multiwoven::Integrations::Source::DatabricksModel::Client

def process_response(response)
  if success?(response)
    data = JSON.parse(response.body)
    [RecordMessage.new(data: data, emitted_at: Time.now.to_i).to_multiwoven_message]
  else
    create_log_message("DATABRICKS MODEL:RUN_MODEL", "error", "request failed: #{response.body}")
  end
end