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