async fn validate_schemas(
source_id: GlobalId,
client: &Client,
publication: &str,
table_info: &BTreeMap<u32, BTreeMap<usize, SourceOutputInfo>>,
is_physical_replica: bool,
) -> Vec<SchemaValidationError>Expand description
Validates the upstream against the source’s expectations once.