feat(*): Migrate from RxJava2 to Reactor

kestra-io · Jan 30, 2024 · 2642e61 · 2642e61
1 parent a231a55
commit 2642e61
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/build.gradle b/build.gradle
@@ -45,7 +45,7 @@ dependencies {
     compileOnly platform("io.micronaut.platform:micronaut-platform:$micronautVersion")
     compileOnly "io.micronaut:micronaut-inject"
     compileOnly "io.micronaut.validation:micronaut-validation"
-    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/spark/SparkCLI.java b/src/main/java/io/kestra/plugin/spark/SparkCLI.java
@@ -119,7 +119,7 @@ public ScriptOutput run(RunContext runContext) throws Exception {
             // spark set all logs in stdErr so we force all logs on info
             .withLogConsumer(new AbstractLogConsumer() {
                 @Override
-                public void accept(String line, Boolean aBoolean) throws Exception {
+                public void accept(String line, Boolean aBoolean) {
                     runContext.logger().info(line);
                 }
             })