Function ingest_from_db 

pub fn ingest_from_db(
    _conn: &str,
    _query: &str,
    _schema: &Schema,
) -> IngestionResult<DataSet>