From d7e3ef68ce3631d070d10cc660e39b419fe187e4 Mon Sep 17 00:00:00 2001 From: hweawer Date: Mon, 16 Dec 2024 14:09:05 +0100 Subject: [PATCH] Run metrics filter on fetch only (#295) --- src/transport/msg_storage.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/transport/msg_storage.py b/src/transport/msg_storage.py index 783d8061..5b7f9f9c 100644 --- a/src/transport/msg_storage.py +++ b/src/transport/msg_storage.py @@ -46,8 +46,9 @@ def get_messages_and_actualize(self, actualize_filter: Callable[[BotMessage], bo """ messages = self.messages for transport in self._transports: - messages.extend(transport.get_messages()) - self.messages = list(filter(lambda x: self._filter(x) and actualize_filter(x), messages)) + filtered_messages = list(filter(lambda x: self._filter(x), transport.get_messages())) + messages.extend(filtered_messages) + self.messages = list(filter(lambda x: actualize_filter(x), messages)) return self.messages def clear(self):