fn verify_schema(
oid: u32,
info: &SourceOutputInfo,
upstream_info: &BTreeMap<u32, PostgresTableDesc>,
) -> Result<(), DefiniteError>fn verify_schema(
oid: u32,
info: &SourceOutputInfo,
upstream_info: &BTreeMap<u32, PostgresTableDesc>,
) -> Result<(), DefiniteError>