From f979fb080d95bcae1ff62d9c5da32e9580acfae4 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lo=C3=AFc=20Mathieu?= Date: Fri, 5 Jan 2024 10:01:14 +0100 Subject: [PATCH] feat(*): Migrate from RxJava2 to Reactor --- build.gradle | 2 +- src/main/java/io/kestra/plugin/dbt/cli/AbstractDbt.java | 2 +- src/main/java/io/kestra/plugin/dbt/cli/DbtCLI.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/build.gradle b/build.gradle index d0c4d56..3677afa 100644 --- 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 index d6ba6cc..b5c74ae 100644 --- 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 index a87414c..274579c 100644 --- 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); } });