diff options
| -rw-r--r-- | app/PluginManager.py | 2 | ||||
| -rw-r--r-- | plugins/ConcatPlugin.py (renamed from app/ConcatPlugin.py) | 0 | ||||
| -rw-r--r-- | plugins/DigestPlugin.py | 0 | ||||
| -rw-r--r-- | plugins/FeedSinkPlugin.py (renamed from app/FeedSinkPlugin.py) | 0 | ||||
| -rw-r--r-- | plugins/FeedSourcePlugin.py (renamed from app/FeedSourcePlugin.py) | 0 | ||||
| -rw-r--r-- | plugins/FilterPlugin.py (renamed from app/FilterPlugin.py) | 0 | ||||
| -rw-r--r-- | plugins/MapPlugin.py (renamed from app/MapPlugin.py) | 2 |
7 files changed, 1 insertions, 3 deletions
diff --git a/app/PluginManager.py b/app/PluginManager.py index f50196e..68149fd 100644 --- a/app/PluginManager.py +++ b/app/PluginManager.py @@ -17,7 +17,7 @@ class PluginManager: self.config = config def load_plugin(self, plugin_name: str) -> None: - module: ModuleType = importlib.import_module(f"app.{plugin_name}") + module: ModuleType = importlib.import_module(f"plugins.{plugin_name}") plugin_class = module.Plugin self._plugins[plugin_name] = plugin_class diff --git a/app/ConcatPlugin.py b/plugins/ConcatPlugin.py index 43d7db2..43d7db2 100644 --- a/app/ConcatPlugin.py +++ b/plugins/ConcatPlugin.py diff --git a/plugins/DigestPlugin.py b/plugins/DigestPlugin.py new file mode 100644 index 0000000..e69de29 --- /dev/null +++ b/plugins/DigestPlugin.py diff --git a/app/FeedSinkPlugin.py b/plugins/FeedSinkPlugin.py index c0fc4c9..c0fc4c9 100644 --- a/app/FeedSinkPlugin.py +++ b/plugins/FeedSinkPlugin.py diff --git a/app/FeedSourcePlugin.py b/plugins/FeedSourcePlugin.py index 575e5d6..575e5d6 100644 --- a/app/FeedSourcePlugin.py +++ b/plugins/FeedSourcePlugin.py diff --git a/app/FilterPlugin.py b/plugins/FilterPlugin.py index 0f2b500..0f2b500 100644 --- a/app/FilterPlugin.py +++ b/plugins/FilterPlugin.py diff --git a/app/MapPlugin.py b/plugins/MapPlugin.py index abc016b..8b5dae7 100644 --- a/app/MapPlugin.py +++ b/plugins/MapPlugin.py @@ -26,8 +26,6 @@ class Plugin(PluginInterface): raise Exception(f"[MapItemPlugin#{self.id}] can not be scheduled") expr = f"map(lambda item: {self.map_expr}, input_feed)" - print("expr:") - print(expr) ret = list(eval(expr, {"input_feed": items, "set_field": set_field})) print(f"[MapItemPlugin#{self.id}] process returning items, n={len(ret)}") return ret |