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