diff options
| author | Jan Tuomi <jans.tuomi@gmail.com> | 2023-09-12 23:11:49 +0300 |
|---|---|---|
| committer | Jan Tuomi <jans.tuomi@gmail.com> | 2023-09-12 23:11:49 +0300 |
| commit | 1fe06b48413c053d072b381fec54d14219088baf (patch) | |
| tree | 01bc8c71b1d6b833cf5e629777ce5e931419286b /plugins/FilterPlugin.py | |
| parent | 5d8f1a622276ceae9985aa0526b1372a0aa19a56 (diff) | |
Improve logging
Diffstat (limited to 'plugins/FilterPlugin.py')
| -rw-r--r-- | plugins/FilterPlugin.py | 10 |
1 files changed, 5 insertions, 5 deletions
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 |
