ag-ingest-aggregator submodule that includes mechanisms for polling a remote data source