Merge pull request #67 from civitaspo/fix/config_error

Catch any initialization exception and re-throw as ConfigException
civitaspo · Jul 29, 2019 · bd7f04c · bd7f04c
2 parents 922cc09 + f03d982
commit bd7f04c
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/src/main/scala/pro/civitaspo/digdag/plugin/athena/AthenaPlugin.scala b/src/main/scala/pro/civitaspo/digdag/plugin/athena/AthenaPlugin.scala
@@ -4,7 +4,7 @@ package pro.civitaspo.digdag.plugin.athena
 import java.lang.reflect.Constructor
 import java.util.{Arrays => JArrays, List => JList}
 
-import io.digdag.client.config.Config
+import io.digdag.client.config.{Config, ConfigException}
 import io.digdag.spi.{Operator, OperatorContext, OperatorFactory, OperatorProvider, Plugin, TemplateEngine}
 import javax.inject.Inject
 import pro.civitaspo.digdag.plugin.athena.add_partition.AthenaAddPartitionOperator
@@ -62,7 +62,12 @@ object AthenaPlugin
                                                                            classOf[OperatorContext],
                                                                            classOf[Config],
                                                                            classOf[TemplateEngine])
-                    constructor.newInstance(operatorName, context, systemConfig, templateEngine)
+                    try {
+                        constructor.newInstance(operatorName, context, systemConfig, templateEngine)
+                    }
+                    catch {
+                        case e: Throwable => throw new ConfigException(e)
+                    }
                 }
             }
         }