pub fn ingest_directory( conn: &Connection<'_>, schema: &SchemaMeta, dir_path: &Path, ) -> Result<IngestResult>