From a7aabfdedfb26e61fed004be5d384971edf0178d Mon Sep 17 00:00:00 2001 From: Vatsal Parekh Date: Mon, 26 Apr 2021 07:28:27 -0500 Subject: [PATCH] Close window after popping the value from store (#137) Co-authored-by: Vatsal Parekh --- faust/tables/base.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/faust/tables/base.py b/faust/tables/base.py index 26608ef14..91ba34939 100644 --- a/faust/tables/base.py +++ b/faust/tables/base.py @@ -375,8 +375,7 @@ async def _del_old_keys(self) -> None: if keys_to_remove: for key in keys_to_remove: value = self.data.pop(key, None) - if key[1][0] > self.last_closed_window: - await self.on_window_close(key, value) + await self.on_window_close(key, value) self.last_closed_window = max( self.last_closed_window, max(key[1][0] for key in keys_to_remove),