From 32682c4076414b41bb267b36b8819895ced99c0d Mon Sep 17 00:00:00 2001
From: Vigith Maurice <vigith@gmail.com>
Date: Sat, 29 Nov 2025 10:56:48 -0800
Subject: [PATCH] chore: upgrade numaflow-rs metadata

Signed-off-by: Vigith Maurice <vigith@gmail.com>
---
 packages/pynumaflow-lite/Cargo.toml             | 2 +-
 packages/pynumaflow-lite/src/map/mod.rs         | 1 +
 packages/pynumaflow-lite/src/source/mod.rs      | 1 +
 packages/pynumaflow-lite/tests/bin/batchmap.rs  | 1 +
 packages/pynumaflow-lite/tests/bin/map.rs       | 3 +++
 packages/pynumaflow-lite/tests/bin/mapstream.rs | 1 +
 packages/pynumaflow-lite/tests/bin/sink.rs      | 2 +-
 7 files changed, 9 insertions(+), 2 deletions(-)

diff --git a/packages/pynumaflow-lite/Cargo.toml b/packages/pynumaflow-lite/Cargo.toml
index c1e6809f..2d0d4dd6 100644
--- a/packages/pynumaflow-lite/Cargo.toml
+++ b/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"
diff --git a/packages/pynumaflow-lite/src/map/mod.rs b/packages/pynumaflow-lite/src/map/mod.rs
index b40d19c8..5dd2e638 100644
--- a/packages/pynumaflow-lite/src/map/mod.rs
+++ b/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,
         }
     }
 }
diff --git a/packages/pynumaflow-lite/src/source/mod.rs b/packages/pynumaflow-lite/src/source/mod.rs
index 3fcd7a7a..a7da35f7 100644
--- a/packages/pynumaflow-lite/src/source/mod.rs
+++ b/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,
         }
     }
 }
diff --git a/packages/pynumaflow-lite/tests/bin/batchmap.rs b/packages/pynumaflow-lite/tests/bin/batchmap.rs
index aa325aaf..88fb697e 100644
--- a/packages/pynumaflow-lite/tests/bin/batchmap.rs
+++ b/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,
diff --git a/packages/pynumaflow-lite/tests/bin/map.rs b/packages/pynumaflow-lite/tests/bin/map.rs
index 42748670..fd3fba1d 100644
--- a/packages/pynumaflow-lite/tests/bin/map.rs
+++ b/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,
diff --git a/packages/pynumaflow-lite/tests/bin/mapstream.rs b/packages/pynumaflow-lite/tests/bin/mapstream.rs
index 981e2d70..0d0ea9ed 100644
--- a/packages/pynumaflow-lite/tests/bin/mapstream.rs
+++ b/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,
diff --git a/packages/pynumaflow-lite/tests/bin/sink.rs b/packages/pynumaflow-lite/tests/bin/sink.rs
index 4d1342ce..bfa604c0 100644
--- a/packages/pynumaflow-lite/tests/bin/sink.rs
+++ b/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(())
 }
-