From 97079428de348cd271f8291ce73613c7501d8b9e Mon Sep 17 00:00:00 2001 From: Saravanan Balasubramanian Date: Tue, 8 Aug 2023 09:23:50 -0700 Subject: [PATCH] lint Signed-off-by: Saravanan Balasubramanian --- numaprom/udf/window.py | 1 - 1 file changed, 1 deletion(-) diff --git a/numaprom/udf/window.py b/numaprom/udf/window.py index 57c8583..51c28cb 100644 --- a/numaprom/udf/window.py +++ b/numaprom/udf/window.py @@ -93,7 +93,6 @@ def window(_: list[str], datum: Datum) -> bytes | None: unique_key, msg["timestamp"], value, win_size, buff_size, recreate=True ) - # Drop message if no of elements is less than sequence length needed if len(elements) < win_size: return None