We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5c83b22 commit 00cfd34Copy full SHA for 00cfd34
quixstreams/dataframe/windows/time_based.py
@@ -468,9 +468,9 @@ def process_window(
468
# Update the session window aggregation
469
aggregated = None
470
if aggregate:
471
- current_value = existing_aggregated if can_extend_session else None
472
- if current_value is None:
473
- current_value = self._initialize_value()
+ current_value = (
+ existing_aggregated if can_extend_session else self._initialize_value()
+ )
474
475
aggregated = self._aggregate_value(current_value, value, timestamp_ms)
476
0 commit comments