class Multiwoven::Integrations::Source::Bigquery::Client

def query(connection, query)
  records = []
  results = connection.query(query) || []
  results.each do |row|
    records << RecordMessage.new(data: row, emitted_at: Time.now.to_i).to_multiwoven_message
  end
  records
end