Add tinydb

1 files changed, 4 insertions, 1 deletions

diff --git a/app/FilterPlugin.py b/app/FilterPlugin.py
index 735540c..4e6ee3b 100644
--- a/app/FilterPlugin.py
+++ b/app/FilterPlugin.py
@@ -10,8 +10,11 @@ class Plugin(PluginInterface):
         self.filter_expr: str = get_param("filter_expr", params)
         print(f"[FilterPlugin#{self.id}] initialized")
 
-    def process(self, items: list[Item]) -> list[Item]:
+    def process(self, source_id: str | None, items: list[Item]) -> list[Item]:
         print(f"[FilterPlugin#{self.id}] process called, n={len(items)}")
+        if source_id is None:
+            raise Exception(f"[FilterPlugin#{self.id}] 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)}")