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 3a67650 commit 120409fCopy full SHA for 120409f
quixstreams/dataframe/windows/time_based.py
@@ -449,9 +449,9 @@ def process_window(
449
# Update the session window aggregation
450
aggregated = None
451
if aggregate:
452
- current_value = existing_aggregated if can_extend_session else None
453
- if current_value is None:
454
- current_value = self._initialize_value()
+ current_value = (
+ existing_aggregated if can_extend_session else self._initialize_value()
+ )
455
456
aggregated = self._aggregate_value(current_value, value, timestamp_ms)
457
0 commit comments