feat(topolotree): implement core fault tolerance protocol

hydro-project · Nov 29, 2023 · 375a10f · 375a10f
1 parent 75c4275
commit 375a10f
Show file tree

Hide file tree

Showing 10 changed files with 295 additions and 792 deletions.
diff --git a/hydro_cli/src/core/deployment.rs b/hydro_cli/src/core/deployment.rs
@@ -106,15 +106,18 @@ impl Deployment {
             .collect::<Vec<_>>();
         self.services = active_services;
 
-        let all_services_start =
-            self.services
-                .iter()
-                .map(|service: &Weak<RwLock<dyn Service>>| async {
-                    service.upgrade().unwrap().write().await.start().await?;
-                    Ok(()) as Result<()>
-                });
-
-        futures::future::try_join_all(all_services_start).await?;
+        progress::ProgressTracker::with_group("start", None, || {
+            let all_services_start =
+                self.services
+                    .iter()
+                    .map(|service: &Weak<RwLock<dyn Service>>| async {
+                        service.upgrade().unwrap().write().await.start().await?;
+                        Ok(()) as Result<()>
+                    });
+
+            futures::future::try_join_all(all_services_start)
+        })
+        .await?;
         Ok(())
     }
 

diff --git a/hydro_cli/src/core/hydroflow_crate/ports.rs b/hydro_cli/src/core/hydroflow_crate/ports.rs
@@ -363,7 +363,7 @@ impl HydroflowSink for HydroflowPortConfig {
                     merge.push(bind_type);
                     merge.len() - 1
                 } else {
-                    panic!()
+                    panic!("Expected a merge connection definition")
                 };
 
                 ServerConfig::MergeSelect(Box::new(base_config), merge_index)

diff --git a/hydro_cli_examples/examples/pn_counter/main.rs b/hydro_cli_examples/examples/pn_counter/main.rs
diff --git a/hydro_cli_examples/examples/pn_counter_delta/main.rs b/hydro_cli_examples/examples/pn_counter_delta/main.rs