feat(*): Migrate from RxJava2 to Reactor

kestra-io · Jan 29, 2024 · f979fb0 · f979fb0
1 parent 4838ae9
commit f979fb0
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/build.gradle b/build.gradle
@@ -46,7 +46,7 @@ dependencies {
     compileOnly "io.micronaut:micronaut-inject"
     compileOnly "io.micronaut.validation:micronaut-validation"
     compileOnly "io.micronaut:micronaut-http-client"
-    compileOnly "io.micronaut.rxjava2:micronaut-rxjava2"
+    compileOnly "io.micronaut.reactor:micronaut-reactor"
 
     // kestra
     compileOnly group: "io.kestra", name: "core", version: kestraVersion

diff --git a/src/main/java/io/kestra/plugin/dbt/cli/AbstractDbt.java b/src/main/java/io/kestra/plugin/dbt/cli/AbstractDbt.java
@@ -147,7 +147,7 @@ public ScriptOutput run(RunContext runContext) throws Exception {
             .withDockerOptions(this.getDocker())
             .withLogConsumer(new AbstractLogConsumer() {
                 @Override
-                public void accept(String line, Boolean isStdErr) throws Exception {
+                public void accept(String line, Boolean isStdErr) {
                     LogService.parse(runContext, line);
                 }
             });

diff --git a/src/main/java/io/kestra/plugin/dbt/cli/DbtCLI.java b/src/main/java/io/kestra/plugin/dbt/cli/DbtCLI.java
@@ -128,7 +128,7 @@ public ScriptOutput run(RunContext runContext) throws Exception {
         CommandsWrapper commands = this.commands(runContext)
             .withLogConsumer(new AbstractLogConsumer() {
                 @Override
-                public void accept(String line, Boolean isStdErr) throws Exception {
+                public void accept(String line, Boolean isStdErr) {
                     LogService.parse(runContext, line);
                 }
             });