class Multiwoven::Integrations::Core::SourceConnector

def query(connection, query)

In every source connector. This will be used for model preview
This needs to be implemented as private method
def query(connection, query)
  # return list of RecordMessage
end