feat: container-level version compatibility check for monovertex (#2108)

Signed-off-by: Keran Yang <[email protected]>
numaproj · Oct 2, 2024 · 3dbed43 · 3dbed43
1 parent 6aacb6e
commit 3dbed43
Show file tree

Hide file tree

Showing 4 changed files with 134 additions and 60 deletions.
diff --git a/rust/numaflow-core/Cargo.toml b/rust/numaflow-core/Cargo.toml
@@ -21,7 +21,6 @@ tracing-subscriber = { version = "0.3.18", features = ["env-filter"] }
 hyper-util = "0.1.6"
 tower = "0.4.13"
 uuid = { version = "1.10.0", features = ["v4"] }
-once_cell = "1.19.0"
 serde_json = "1.0.122"
 numaflow-models = { path = "../numaflow-models" }
 trait-variant = "0.1.2"

diff --git a/rust/numaflow-core/src/monovertex.rs b/rust/numaflow-core/src/monovertex.rs
@@ -244,7 +244,7 @@ mod tests {
         let (src_shutdown_tx, src_shutdown_rx) = tokio::sync::oneshot::channel();
         let tmp_dir = tempfile::TempDir::new().unwrap();
         let src_sock_file = tmp_dir.path().join("source.sock");
-        let src_info_file = tmp_dir.path().join("source-server-info");
+        let src_info_file = tmp_dir.path().join("sourcer-server-info");
         let server_info_obj = ServerInfo {
             protocol: "uds".to_string(),
             language: "rust".to_string(),
@@ -271,7 +271,7 @@ mod tests {
         let (sink_shutdown_tx, sink_shutdown_rx) = tokio::sync::oneshot::channel();
         let tmp_dir = tempfile::TempDir::new().unwrap();
         let sink_sock_file = tmp_dir.path().join("sink.sock");
-        let sink_server_info = tmp_dir.path().join("sink-server-info");
+        let sink_server_info = tmp_dir.path().join("sinker-server-info");
 
         write_server_info(sink_server_info.to_str().unwrap(), &server_info_obj)
             .await