Upgrade to timely and DD 0.12.0

connect/Cargo.toml

@@ -10,4 +10,4 @@ license = "MIT"
 edition = "2018"
 
 [dependencies]
-timely = "^0.11"
+timely = "^0.12.0"

connect/src/receive/replaywithshutdown.rs

@@ -64,8 +64,8 @@ where I : IntoIterator,
                     // The first thing we do is modify our capabilities to match the number of streams we manage.
                     // This should be a simple change of `self.event_streams.len() - 1`. We only do this once, as
                     // our very first action.
-                    progress.internals[0].update(Default::default(), (event_streams.len() as i64) - 1);
-                    antichain.update_iter(Some((Default::default(), (event_streams.len() as i64) - 1)).into_iter());
+                    progress.internals[0].update(T::minimum(), (event_streams.len() as i64) - 1);
+                    antichain.update_iter(Some((T::minimum(), (event_streams.len() as i64) - 1)).into_iter());
                     started = true;
                 }
 

tdiag/Cargo.toml

@@ -10,8 +10,8 @@ license = "MIT"
 edition = "2018"
 
 [dependencies]
-timely = "^0.11"
-differential-dataflow = "^0.11"
+timely = "^0.12.0"
+differential-dataflow = "^0.12.0"
 clap = "^2.33"
 # tdiag-connect = "^0.2"
 tdiag-connect = { path = "../connect" }

tdiag/src/commands/arrangements.rs

@@ -26,7 +26,7 @@ use tdiag_connect::receive::ReplayWithShutdown;
 /// compaction events and derive number of tuples for each trace;
 /// 3. prints the current size alongside arrangement names;
 pub fn listen(
-    timely_configuration: timely::Configuration,
+    timely_configuration: timely::Config,
     timely_sockets: Vec<Option<std::net::TcpStream>>,
     differential_sockets: Vec<Option<std::net::TcpStream>>,
     output_interval_ms: u64, 

tdiag/src/commands/graph.rs

@@ -26,7 +26,7 @@ static GRAPH_HTML: &str = include_str!("graph/dataflow-graph.html");
 ///
 /// This module includes `graph/dataflow-graph.html` as a static resource.
 pub fn listen_and_render(
-    timely_configuration: timely::Configuration,
+    timely_configuration: timely::Config,
     sockets: Vec<Option<std::net::TcpStream>>,
     output_path: &std::path::Path) -> Result<(), crate::DiagError> {
 

tdiag/src/commands/profile.rs

@@ -14,6 +14,7 @@ use differential_dataflow::operators::{Join, reduce::Threshold, Consolidate, arr
 use timely::logging::TimelyEvent::{Operates, Schedule};
 
 use tdiag_connect::receive::ReplayWithShutdown;
+use timely::progress::frontier::AntichainRef;
 
 /// Prints aggregate time spent in each scope/operator.
 ///
@@ -24,7 +25,7 @@ use tdiag_connect::receive::ReplayWithShutdown;
 /// 3. prints the resulting measurements alongside operator names and
 /// scope names;
 pub fn listen_and_profile(
-    timely_configuration: timely::Configuration,
+    timely_configuration: timely::Config,
     sockets: Vec<Option<std::net::TcpStream>>) -> Result<(), crate::DiagError> {
 
     let sockets = Arc::new(Mutex::new(sockets));
@@ -119,7 +120,7 @@ pub fn listen_and_profile(
 
         let mut profile_trace = profile_trace;
 
-        profile_trace.distinguish_since(&[]);
+        profile_trace.set_physical_compaction(AntichainRef::new(&[]));
 
         let (mut cursor, storage) = profile_trace.cursor();
 

tdiag/src/main.rs

@@ -106,8 +106,8 @@ variable pointing to tdiag's differential port (51318 by default).
         .parse().map_err(|e| DiagError(format!("Invalid --diag-workers: {}", e)))?;
 
     let timely_configuration = match diag_workers {
-        1 => timely::Configuration::Thread,
-        n => timely::Configuration::Process(n),
+        1 => timely::Config::thread(),
+        n => timely::Config::process(n),
     };
 
     match args.subcommand() {