class Multiwoven::Integrations::Source::WatsonxData::Client

def query(connection, query)
  response = execute_query(connection, query)
  response = JSON.parse(response.body).with_indifferent_access
  records = response[:response][:result]
  records.map do |row|
    RecordMessage.new(data: row, emitted_at: Time.now.to_i).to_multiwoven_message
  end
end