Add fix for using reducer with window with test added

Author: Hoang Phan

quixstreams/dataframe/windows/aggregations.py

@@ -348,6 +348,7 @@ def __init__(
         reducer: Callable[[R, Any], R],
         initializer: Callable[[Any], R],
     ) -> None:
+        super().__init__()
         self._initializer: Callable[[Any], R] = initializer
         self._reducer: Callable[[R, Any], R] = reducer
 

tests/test_quixstreams/test_dataframe/test_windows/test_aggregations.py

@@ -176,6 +176,7 @@ def test_other_aggregation(self, aggregator, values, expected):
             (Mean(), "Mean"),
             (Max(), "Max"),
             (Min(), "Min"),
+            (Reduce(reducer=lambda old, new: old + new, initializer=lambda x: x), "Reduce"),
             (Count("value"), "Count/value"),
             (Sum("value"), "Sum/value"),
             (Mean("value"), "Mean/value"),