From 592b998a99813aa774e7e9669cd8bb86166edd2e Mon Sep 17 00:00:00 2001 From: Avik Basu Date: Mon, 10 Jul 2023 12:30:21 -0700 Subject: [PATCH] minor fix Signed-off-by: Avik Basu --- numaprom/udf/postprocess.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/numaprom/udf/postprocess.py b/numaprom/udf/postprocess.py index 6daaf84..546ac28 100644 --- a/numaprom/udf/postprocess.py +++ b/numaprom/udf/postprocess.py @@ -154,7 +154,7 @@ def _publish(final_score: float, payload: StreamPayload) -> list[bytes]: ) # If the unified anomaly is -1, we don't want to publish it - if unified_anomaly > 0: + if unified_anomaly >= 0: unified_json = __construct_unified_payload( payload, unified_anomaly, unified_config ).as_json()