From 583541924e16a0fe4156628f0c24f4116481f1ff Mon Sep 17 00:00:00 2001
From: Moritz Hoffmann <antiguru@gmail.com>
Date: Tue, 29 Oct 2024 19:26:11 +0100
Subject: [PATCH] Fix interactive (#533)

Signed-off-by: Moritz Hoffmann <antiguru@gmail.com>
---
 Cargo.toml                  | 2 +-
 interactive/Cargo.toml      | 4 ++--
 interactive/src/plan/mod.rs | 2 +-
 interactive/src/plan/sfw.rs | 6 +++---
 4 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/Cargo.toml b/Cargo.toml
index 16c7cfbbd..3d4e39211 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -21,7 +21,7 @@ members = [
     # "advent_of_code_2017",
     "dogsdogsdogs",
     "experiments",
-    #"interactive",
+    "interactive",
     "server",
     "server/dataflows/degr_dist",
     "server/dataflows/neighborhood",
diff --git a/interactive/Cargo.toml b/interactive/Cargo.toml
index 73b578a9c..cf4938447 100644
--- a/interactive/Cargo.toml
+++ b/interactive/Cargo.toml
@@ -9,6 +9,6 @@ publish = false
 bincode = "1"
 serde = { version = "1", features = ["derive"]}
 differential-dataflow = { path = "../" }
-dogsdogsdogs = { path = "../dogsdogsdogs" }
-timely = { git = "https://github.com/TimelyDataflow/timely-dataflow", features = ["bincode"] }
+differential-dogs3 = { path = "../dogsdogsdogs" }
+timely = { workspace = true }
 #timely = { path = "../../timely-dataflow/timely", features = ["bincode"] }
diff --git a/interactive/src/plan/mod.rs b/interactive/src/plan/mod.rs
index ce76cbaa1..45a6002cd 100644
--- a/interactive/src/plan/mod.rs
+++ b/interactive/src/plan/mod.rs
@@ -170,7 +170,7 @@ impl<V: ExchangeData+Hash+Datum> Render for Plan<V> {
                         input_arrangement
                     };
 
-                    let output = input.reduce_abelian::<_,KeySpine<_,_,_>>("Distinct", move |_,_,t| t.push(((), 1)));
+                    let output = input.reduce_abelian::<_,_,_,KeySpine<_,_,_>>("Distinct", move |_,_,t| t.push(((), 1)));
 
                     arrangements.set_unkeyed(&self, &output.trace);
                     output.as_collection(|k,&()| k.clone())
diff --git a/interactive/src/plan/sfw.rs b/interactive/src/plan/sfw.rs
index 711b71ce5..9709d4375 100644
--- a/interactive/src/plan/sfw.rs
+++ b/interactive/src/plan/sfw.rs
@@ -230,7 +230,7 @@ impl<V: ExchangeData+Hash+Datum> Render for MultiwayJoin<V> {
             }
 
             // Build the dataflow.
-            use dogsdogsdogs::altneu::AltNeu;
+            use differential_dogs3::altneu::AltNeu;
 
             let scope_name = format!("DeltaRule: {}/{}", index, self.sources.len());
             let changes = scope.clone().scoped::<AltNeu<_>,_,_>(&scope_name, |inner| {
@@ -250,11 +250,11 @@ impl<V: ExchangeData+Hash+Datum> Render for MultiwayJoin<V> {
                     changes =
                     if join_idx < index {
                         let arrangement = trace.import(scope).enter_at(inner, |_,_,t| AltNeu::alt(t.clone()), |_| unimplemented!());
-                        dogsdogsdogs::operators::propose(&changes, arrangement, key_selector)
+                        differential_dogs3::operators::propose(&changes, arrangement, key_selector)
                     }
                     else {
                         let arrangement = trace.import(scope).enter_at(inner, |_,_,t| AltNeu::neu(t.clone()), |_| unimplemented!());
-                        dogsdogsdogs::operators::propose(&changes, arrangement, key_selector)
+                        differential_dogs3::operators::propose(&changes, arrangement, key_selector)
                     }
                     .map(|(mut prefix, extensions)| { prefix.extend(extensions.into_iter()); prefix })
                     ;