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 4d5e48e commit 4afdc6bCopy full SHA for 4afdc6b
quixstreams/dataframe/windows/time_based.py
@@ -271,7 +271,7 @@ def process_window(
271
# Combine triggered windows with time-expired windows
272
all_expired_windows = triggered_windows + list(expired_windows)
273
274
- return updated_windows, iter(all_expired_windows)
+ return updated_windows, all_expired_windows
275
276
def expire_by_partition(
277
self,
0 commit comments