feat(core): don't failed on startup for invalid plugin

kestra-io · Sep 8, 2023 · c880df6 · c880df6
1 parent a2c81b2
commit c880df6
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/core/src/main/java/io/kestra/core/plugins/PluginScanner.java b/core/src/main/java/io/kestra/core/plugins/PluginScanner.java
@@ -104,7 +104,13 @@ private RegisteredPlugin scanClassLoader(final ClassLoader classLoader, External
         loader.collectAll(definitions);
 
         for (BeanIntrospectionReference definition : definitions) {
-            Class beanType = definition.getBeanType();
+            Class beanType;
+            try {
+                beanType = definition.getBeanType();
+            } catch (Throwable e) {
+                log.warn("Unable to load class '{}' on plugin '{}'", definition.getName(), externalPlugin.getLocation().toString());
+                continue;
+            }
 
             if (Modifier.isAbstract(beanType.getModifiers())) {
                 continue;