fix: implement runnable task for mysql

kestra-io · Oct 17, 2024 · f9ad8e3 · f9ad8e3
1 parent 69fad9c
commit f9ad8e3
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/plugin-jdbc-mysql/src/main/java/io/kestra/plugin/jdbc/mysql/Queries.java b/plugin-jdbc-mysql/src/main/java/io/kestra/plugin/jdbc/mysql/Queries.java
@@ -3,10 +3,13 @@
 import io.kestra.core.models.annotations.Example;
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.annotations.PluginProperty;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.PluginUtilsService;
 import io.kestra.core.runners.RunContext;
 import io.kestra.plugin.jdbc.AbstractCellConverter;
+import io.kestra.plugin.jdbc.AbstractJdbcBaseQuery;
 import io.kestra.plugin.jdbc.AbstractJdbcQueries;
+import io.kestra.plugin.jdbc.AbstractJdbcQuery;
 import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.AccessLevel;
 import lombok.EqualsAndHashCode;
@@ -40,7 +43,7 @@
         )
     }
 )
-public class Queries extends AbstractJdbcQueries {
+public class Queries extends AbstractJdbcQueries implements RunnableTask<AbstractJdbcQueries.MultiQueryOutput> {
 
     @Schema(
         title = "Add input file to be loaded with `LOAD DATA LOCAL`.",