async fn purify_source_format_single( format: &mut Format<Raw>, connector: &mut CreateSourceConnector, envelope: &Envelope, file: Option<File>, connector_options: &BTreeMap<String, String>, with_options: &Vec<SqlOption<Raw>>) -> Result<(), Error>