chore: upgrade numaflow-rs ro support metadata minimally (#289)

Author: vigith

packages/pynumaflow-lite/Cargo.toml

@@ -9,7 +9,7 @@ name = "pynumaflow_lite"
 crate-type = ["cdylib", "rlib"]
 
 [dependencies]
-numaflow = { git = "https://github.com/numaproj/numaflow-rs.git", rev = "fde3deafea634abbc347032ff409d33d4e1514b1" }
+numaflow = { git = "https://github.com/numaproj/numaflow-rs.git", rev = "42a1e814459d18b89eb6ca874fd0a989fd134303" }
 pyo3 = { version = "0.27.1", features = ["chrono", "experimental-inspect"] }
 tokio = "1.47.1"
 tonic = "0.14.2"

packages/pynumaflow-lite/src/map/mod.rs

@@ -82,6 +82,7 @@ impl From<Message> for map::Message {
             keys: value.keys,
             value: value.value,
             tags: value.tags,
+            user_metadata: None,
         }
     }
 }

packages/pynumaflow-lite/src/source/mod.rs

@@ -84,6 +84,7 @@ impl From<Message> for numaflow::source::Message {
             event_time: value.event_time,
             keys: value.keys,
             headers: value.headers,
+            user_metadata: None,
         }
     }
 }

packages/pynumaflow-lite/tests/bin/batchmap.rs

@@ -61,6 +61,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
                 watermark: Some(prost_types::Timestamp::default()),
                 event_time: Some(prost_types::Timestamp::default()),
                 headers: HashMap::new(),
+                metadata: None,
             }),
             id: id.to_string(),
             handshake: None,

packages/pynumaflow-lite/tests/bin/map.rs

@@ -64,6 +64,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
             watermark: Some(prost_types::Timestamp::default()),
             event_time: Some(prost_types::Timestamp::default()),
             headers: Default::default(),
+            metadata: None,
         }),
         id: "".to_string(),
         handshake: None,
@@ -97,6 +98,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
             watermark: Some(prost_types::Timestamp::default()),
             event_time: Some(prost_types::Timestamp::default()),
             headers: Default::default(),
+            metadata: None,
         }),
         id: "".to_string(),
         handshake: None,
@@ -118,6 +120,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
             watermark: Some(prost_types::Timestamp::default()),
             event_time: Some(prost_types::Timestamp::default()),
             headers: Default::default(),
+            metadata: None,
         }),
         id: "".to_string(),
         handshake: None,

packages/pynumaflow-lite/tests/bin/mapstream.rs

@@ -43,6 +43,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
             watermark: Some(prost_types::Timestamp::default()),
             event_time: Some(prost_types::Timestamp::default()),
             headers: Default::default(),
+            metadata: None,
         }),
         id: "".to_string(),
         handshake: None,

packages/pynumaflow-lite/tests/bin/sink.rs

@@ -61,6 +61,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
                 event_time: Some(prost_types::Timestamp::default()),
                 id: id.to_string(),
                 headers: HashMap::new(),
+                metadata: None,
             }),
             handshake: None,
             status: None,
@@ -117,4 +118,3 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
     Ok(())
 }
-