Update timely/src/dataflow/operators/capability.rs

frankmcsherry · antiguru · web-flow · commit b499ea24cecb · 2025-08-12T16:11:55.000-04:00
Co-authored-by: Moritz Hoffmann &lt;antiguru@gmail.com&gt;
diff --git a/timely/src/dataflow/operators/capability.rs b/timely/src/dataflow/operators/capability.rs
@@ -250,7 +250,7 @@ impl<T: Timestamp> CapabilityTrait<T> for InputCapability<T> {
         let internal_borrow = self.internal.borrow();
         // To be valid, the output buffer must match and the timestamp summary needs to be the default.
         Rc::ptr_eq(&internal_borrow[port], query_buffer) &&
-        summaries_borrow.get(port).map(|path| path.len() == 1 && path[0] == Default::default()).unwrap_or(false)
+        summaries_borrow.get(port).map_or(false, |path| path.elements() == [Default::default()])
     }
 }
 

Original file line number	Diff line number	Diff line change
`@@ -250,7 +250,7 @@ impl<T: Timestamp> CapabilityTrait<T> for InputCapability<T> {`
`250`	`250`	`let internal_borrow = self.internal.borrow();`
`251`	`251`	`// To be valid, the output buffer must match and the timestamp summary needs to be the default.`
`252`	`252`	`Rc::ptr_eq(&internal_borrow[port], query_buffer) &&`
`253`		`- summaries_borrow.get(port).map(\|path\| path.len() == 1 && path[0] == Default::default()).unwrap_or(false)`
	`253`	`+ summaries_borrow.get(port).map_or(false, \|path\| path.elements() == [Default::default()])`
`254`	`254`	`}`
`255`	`255`	`}`
`256`	`256`