From 2a03ef96a807d7c4b428f8e46c41d528f051bd0f Mon Sep 17 00:00:00 2001 From: Moritz Hoffmann Date: Fri, 13 Mar 2026 14:17:35 +0100 Subject: [PATCH] Compatibility fix with unreleased Timely Signed-off-by: Moritz Hoffmann --- differential-dataflow/src/input.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/differential-dataflow/src/input.rs b/differential-dataflow/src/input.rs index 3fd612107..43a4987e8 100644 --- a/differential-dataflow/src/input.rs +++ b/differential-dataflow/src/input.rs @@ -258,7 +258,7 @@ impl InputSession { /// called, all buffers are flushed and timely dataflow is advised that some logical times are no longer possible. pub fn flush(&mut self) { self.handle.send_batch(&mut self.buffer); - if self.handle.epoch().less_than(&self.time) { + if self.handle.time().less_than(&self.time) { self.handle.advance_to(self.time.clone()); } } @@ -269,7 +269,7 @@ impl InputSession { /// the session is dropped or flushed. It is not correct to use this time as a basis for a computation's `step_while` /// method unless the session has just been flushed. pub fn advance_to(&mut self, time: T) { - assert!(self.handle.epoch().less_equal(&time)); + assert!(self.handle.time().less_equal(&time)); assert!(&self.time.less_equal(&time)); self.time = time; }