When loading plugin configs, catch KeyError on unavailable plugins and list all available.

Signed-off-by: Pedro Algarvio <[email protected]>

Author: s0undt3ch

changelog/68.improvement.rst

@@ -0,0 +1,3 @@
+Several improvements to the project
+
+* When loading plugin configs, catch `KeyError` on unavailable plugins and list all available.

src/saf/models.py

@@ -109,7 +109,15 @@ def loaded_plugin(self: CCB) -> ModuleType:
         """
         Return the plugin instance(module) for which this configuration refers to.
         """
-        return PluginsList.instance().collectors[self.plugin]
+        try:
+            return PluginsList.instance().collectors[self.plugin]
+        except KeyError as exc:
+            log.warning(
+                "Failed to load %r collector plugin. Available collector plugins: %s",
+                self.plugin,
+                list(PluginsList.instance().collectors),
+            )
+            raise exc from None
 
 
 PCB = TypeVar("PCB", bound="ProcessConfigBase")
@@ -125,7 +133,15 @@ def loaded_plugin(self: PCB) -> ModuleType:
         """
         Return the plugin instance(module) for which this configuration refers to.
         """
-        return PluginsList.instance().processors[self.plugin]
+        try:
+            return PluginsList.instance().processors[self.plugin]
+        except KeyError as exc:
+            log.warning(
+                "Failed to load %r processor plugin. Available processor plugins: %s",
+                self.plugin,
+                list(PluginsList.instance().processors),
+            )
+            raise exc from None
 
 
 FCB = TypeVar("FCB", bound="ForwardConfigBase")
@@ -141,7 +157,15 @@ def loaded_plugin(self: FCB) -> ModuleType:
         """
         Return the plugin instance(module) for which this configuration refers to.
         """
-        return PluginsList.instance().forwarders[self.plugin]
+        try:
+            return PluginsList.instance().forwarders[self.plugin]
+        except KeyError as exc:
+            log.warning(
+                "Failed to load %r forwarder plugin. Available forwarder plugins: %s",
+                self.plugin,
+                list(PluginsList.instance().forwarders),
+            )
+            raise exc from None
 
 
 PC = TypeVar("PC", bound="PipelineConfig")