class Multiwoven::Integrations::Source::Postgresql::Client

def query(connection, query)
  connection.exec(query) do |result|
    result.map do |row|
      RecordMessage.new(data: row, emitted_at: Time.now.to_i).to_multiwoven_message
    end
  end
end