diff options
Diffstat (limited to 'app/FilterPlugin.py')
| -rw-r--r-- | app/FilterPlugin.py | 10 |
1 files changed, 3 insertions, 7 deletions
diff --git a/app/FilterPlugin.py b/app/FilterPlugin.py index fd3984a..735540c 100644 --- a/app/FilterPlugin.py +++ b/app/FilterPlugin.py @@ -10,13 +10,9 @@ class Plugin(PluginInterface): self.filter_expr: str = get_param("filter_expr", params) print(f"[FilterPlugin#{self.id}] initialized") - def validate_input_n(self, n: int) -> bool: - return n == 1 - - def process(self, inputs: list[list[Item]]) -> list[Item]: - input_feed: list[Item] = inputs[0] - print(f"[FilterPlugin#{self.id}] process called, n={len(input_feed)}") + def process(self, items: list[Item]) -> list[Item]: + print(f"[FilterPlugin#{self.id}] process called, n={len(items)}") expr = f"filter(lambda item: {self.filter_expr}, input_feed)" - ret = list(eval(expr, {"input_feed": input_feed})) + ret = list(eval(expr, {"input_feed": items})) print(f"[FilterPlugin#{self.id}] process returning items, n={len(ret)}") return ret |
