Skip to content

Commit 367d212

Browse files
authored
refactor: watermark to not use actor pattern (#3039)
Signed-off-by: Yashash H L <[email protected]>
1 parent edb2252 commit 367d212

File tree

7 files changed

+214
-610
lines changed

7 files changed

+214
-610
lines changed

rust/numaflow-core/src/metrics.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1083,15 +1083,15 @@ pub async fn watermark_handler<C: crate::typ::NumaflowTypeConfig>(
10831083
// For source watermark handle, always fetch only partition 0
10841084
// Source vertices don't have a 'from' vertex, so ignore the query parameter
10851085
WatermarkHandle::Source(source_handle) => {
1086-
let mut handle_clone = source_handle.clone();
1086+
let handle_clone = source_handle.clone();
10871087
let watermark = handle_clone.fetch_head_watermark(0).await;
10881088
partitions.insert("0".to_string(), watermark.timestamp_millis());
10891089
}
10901090

10911091
// For ISB vertices, fetch watermarks for all partitions
10921092
// If 'from' query parameter is provided, fetch watermarks only for that specific edge
10931093
WatermarkHandle::ISB(isb_handle) => {
1094-
let mut handle_clone = isb_handle.clone();
1094+
let handle_clone = isb_handle.clone();
10951095

10961096
// For reduce vertices, only return partition 0 since they read from single partition
10971097
// For other vertex types, fetch watermarks for all partitions

0 commit comments

Comments
 (0)