Remove redundant if

gwaramadze · gwaramadze · commit 4cdd489e9408 · 2025-08-05T16:29:50.000+02:00
diff --git a/quixstreams/dataframe/windows/time_based.py b/quixstreams/dataframe/windows/time_based.py
@@ -454,9 +454,6 @@ def process_window(
             )
 
             aggregated = self._aggregate_value(current_value, value, timestamp_ms)
-
-        # Output intermediate results for aggregations
-        if aggregate:
             updated_windows.append(
                 (
                     key,

Original file line number	Diff line number	Diff line change
`@@ -454,9 +454,6 @@ def process_window(`
`454`	`454`	`)`
`455`	`455`
`456`	`456`	`aggregated = self._aggregate_value(current_value, value, timestamp_ms)`
`457`		`-`
`458`		`- # Output intermediate results for aggregations`
`459`		`- if aggregate:`
`460`	`457`	`updated_windows.append(`
`461`	`458`	`(`
`462`	`459`	`key,`