From 1fe06b48413c053d072b381fec54d14219088baf Mon Sep 17 00:00:00 2001 From: Jan Tuomi Date: Tue, 12 Sep 2023 23:11:49 +0300 Subject: Improve logging --- plugins/FilterPlugin.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) (limited to 'plugins/FilterPlugin.py') diff --git a/plugins/FilterPlugin.py b/plugins/FilterPlugin.py index 11cbc68..85c2229 100644 --- a/plugins/FilterPlugin.py +++ b/plugins/FilterPlugin.py @@ -5,16 +5,16 @@ from app.utils import get_config class Plugin(PluginInterface): def __init__(self, id: str, params: Params) -> None: - super().__init__(id, params) + super().__init__("FilterPlugin", id, params) self.filter_expr: str = get_config(params, "filter_expr") - print(f"[FilterPlugin#{self.id}] initialized") + self.log("initialized") def process(self, source_id: str | None, items: list[Item]) -> list[Item]: - print(f"[FilterPlugin#{self.id}] process called, n={len(items)}") + self.log(f"filtering {len(items)} with given filter expression") if source_id is None: - raise Exception(f"[FilterPlugin#{self.id}] can not be scheduled") + raise Exception(f"{self.log_prefix} can not be scheduled") expr = f"filter(lambda item: {self.filter_expr}, input_feed)" ret = list(eval(expr, {"input_feed": items})) - print(f"[FilterPlugin#{self.id}] process returning items, n={len(ret)}") + self.log(f"filtering done, {len(ret)} passed filter") return ret -- cgit v1.3