Fix typo in FixedTimeWindowDefinition.reduce docstring (#501)

gwaramadze · web-flow · commit 102494e55f0a · 2024-09-18T11:23:24.000+02:00
diff --git a/quixstreams/dataframe/windows/definitions.py b/quixstreams/dataframe/windows/definitions.py
@@ -164,7 +164,7 @@ def reduce(
         def reducer(agg: dict, current: int):
             aggregated = {
                 'min': min(agg['min'], current),
-                'max': max(agg['max'], current)
+                'max': max(agg['max'], current),
                 'count': agg['count'] + 1
             }
             return aggregated

Original file line number	Diff line number	Diff line change
`@@ -164,7 +164,7 @@ def reduce(`
`164`	`164`	`def reducer(agg: dict, current: int):`
`165`	`165`	`aggregated = {`
`166`	`166`	`'min': min(agg['min'], current),`
`167`		`- 'max': max(agg['max'], current)`
	`167`	`+ 'max': max(agg['max'], current),`
`168`	`168`	`'count': agg['count'] + 1`
`169`	`169`	`}`
`170`	`170`	`return aggregated`