From 3fd689f86204588e53cf1689bfdbfbde482e642b Mon Sep 17 00:00:00 2001 From: Yashash H L Date: Tue, 11 Feb 2025 21:36:26 +0530 Subject: [PATCH] fix unit test Signed-off-by: Yashash H L --- rust/numaflow-core/src/watermark/idle/source.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rust/numaflow-core/src/watermark/idle/source.rs b/rust/numaflow-core/src/watermark/idle/source.rs index 0c125f5251..1405b67066 100644 --- a/rust/numaflow-core/src/watermark/idle/source.rs +++ b/rust/numaflow-core/src/watermark/idle/source.rs @@ -139,7 +139,7 @@ mod tests { // Update and fetch idle watermark with computed_wm = -1 let idle_wm = manager.update_and_fetch_idle_wm(-1); - assert!(idle_wm > 0); + assert_eq!(idle_wm, -1); // Update and fetch idle watermark with a valid computed_wm let idle_wm = manager.update_and_fetch_idle_wm(1000);