Fixed bug in DataSourceIngestPipeline