diff --git a/airbyte-to-flow/src/interceptors/fix_document_schema.rs b/airbyte-to-flow/src/interceptors/fix_document_schema.rs index db6ee69613d5..e84bb86612bc 100644 --- a/airbyte-to-flow/src/interceptors/fix_document_schema.rs +++ b/airbyte-to-flow/src/interceptors/fix_document_schema.rs @@ -187,6 +187,9 @@ pub fn fix_nonstandard_jsonschema_attributes(schema: &mut serde_json::Value) { if f == "int32" || f == "int64" { // Insert updates values map.insert("format".to_string(), json!("integer")); + } else if f == "base64" { + // a non-standard format output by salesforce connector + map.remove("format"); } } }, @@ -540,7 +543,8 @@ mod test { }, "id": { "type": ["string", "null"], - "group": "test" + "group": "test", + "format": "base64" } } }