Skip to content

Commit c9b9e4f

Browse files
Test against TD with linear reachability (#588)
1 parent 6d505af commit c9b9e4f

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ resolver = "2"
1717

1818
[workspace.dependencies]
1919
differential-dataflow = { path = "differential-dataflow", default-features = false, version = "0.13.7" }
20-
timely = { version = "0.19", default-features = false }
20+
timely = { version = "0.20", default-features = false }
2121
#timely = { path = "../timely-dataflow/timely/", default-features = false }
2222

2323
[profile.release]

differential-dataflow/src/dynamic/mod.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ where
4343
// Create a unary operator that will strip all but `level-1` timestamp coordinates.
4444
let mut builder = OperatorBuilder::new("LeaveDynamic".to_string(), self.scope());
4545
let (mut output, stream) = builder.new_output();
46-
let mut input = builder.new_input_connection(&self.inner, Pipeline, vec![Antichain::from_elem(Product { outer: Default::default(), inner: PointStampSummary { retain: Some(level - 1), actions: Vec::new() } })]);
46+
let mut input = builder.new_input_connection(&self.inner, Pipeline, [(0, Antichain::from_elem(Product { outer: Default::default(), inner: PointStampSummary { retain: Some(level - 1), actions: Vec::new() } }))]);
4747

4848
builder.build(move |_capability| move |_frontier| {
4949
let mut output = output.activate();

0 commit comments

Comments
 (0)