We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
ChangeBatch
1 parent 54f9b49 commit a44b882Copy full SHA for a44b882
timely/src/dataflow/operators/capability.rs
@@ -151,8 +151,10 @@ impl<T: Timestamp> Capability<T> {
151
///
152
/// Returns a [DowngradeError] if `self.time` is not less or equal to `new_time`.
153
pub fn try_downgrade(&mut self, new_time: &T) -> Result<(), DowngradeError> {
154
- if let Some(new_capability) = self.try_delayed(new_time) {
155
- *self = new_capability;
+ if self.time.less_equal(new_time) {
+ if &self.time != new_time {
156
+ *self = Self::new(new_time.clone(), self.internal.clone());
157
+ }
158
Ok(())
159
} else {
160
Err(DowngradeError(()))
0 commit comments