We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ec3ac3e commit a7aabfdCopy full SHA for a7aabfd
faust/tables/base.py
@@ -375,8 +375,7 @@ async def _del_old_keys(self) -> None:
375
if keys_to_remove:
376
for key in keys_to_remove:
377
value = self.data.pop(key, None)
378
- if key[1][0] > self.last_closed_window:
379
- await self.on_window_close(key, value)
+ await self.on_window_close(key, value)
380
self.last_closed_window = max(
381
self.last_closed_window,
382
max(key[1][0] for key in keys_to_remove),
0 commit comments