diff --git a/crates/validation/src/collection.rs b/crates/validation/src/collection.rs index 0d21e372cf..1567372192 100644 --- a/crates/validation/src/collection.rs +++ b/crates/validation/src/collection.rs @@ -94,9 +94,7 @@ fn walk_collection( let read_bundle = models::Schema::extend_read_bundle( read_bundle, write_bundle, - inferred_schemas - .get(&collection.collection) - .map(|v| &v.schema), + inferred_schema.map(|v| &v.schema), ); let read_schema = diff --git a/crates/validation/src/lib.rs b/crates/validation/src/lib.rs index f9b8abb724..77187f4cd4 100644 --- a/crates/validation/src/lib.rs +++ b/crates/validation/src/lib.rs @@ -132,7 +132,7 @@ pub async fn validate( scope: url::Url::parse("flow://control-plane").unwrap(), spec, validated: None, - // Note that we don't currently fetch the infeered schema md5 for remote collections, + // Note that we don't currently fetch the infered schema md5 for remote collections, // so they won't appear in the build ouptut for these collections. inferred_schema_md5: None, }