Skip to content

Commit d61a2b8

Browse files
committed
Merge branch 'stack/requested-728' into stack/requested-763
2 parents 050b2d7 + 59a4e0a commit d61a2b8

2 files changed

Lines changed: 7 additions & 6 deletions

File tree

‎control_plane/tests/issue754_level1.rs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,7 @@ fn assert_selected_plan(name: &str, plan: &CompiledPhysicalPlan) -> Option<Strin
123123
for materialization in &plan.precompute_plan.materializations {
124124
let definition = plan
125125
.summary_catalog
126-
.materializations
126+
.definitions
127127
.get(&materialization.policy_fingerprint().into())
128128
.expect("precompute producer has no catalog definition");
129129
let descriptor =

‎crates/asap_types/src/derived_input.rs‎

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -37,11 +37,12 @@ impl DerivedInputIdentity {
3737
root: PostAsapNodeId,
3838
frontiers: &BTreeMap<PostAsapNodeId, SummaryDefinitionId>,
3939
) -> Result<Self, String> {
40-
if !matches!(
41-
document.schema_version,
42-
crate::executable_plan::OWNED_POST_ASAP_DAG_SCHEMA_VERSION
43-
| crate::executable_plan::MAINTENANCE_DAG_SCHEMA_VERSION
44-
) {
40+
if ![
41+
crate::executable_plan::OWNED_POST_ASAP_DAG_SCHEMA_VERSION,
42+
crate::executable_plan::MAINTENANCE_DAG_SCHEMA_VERSION,
43+
]
44+
.contains(&document.schema_version)
45+
{
4546
return Err("unsupported derived program document version".into());
4647
}
4748
let decoded = document.decode()?;

0 commit comments

Comments
 (0)