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 549503e..6640268 100644 --- a/src/main/java/io/kestra/plugin/dbt/cli/DbtCLI.java +++ b/src/main/java/io/kestra/plugin/dbt/cli/DbtCLI.java @@ -250,7 +250,7 @@ public void accept(String line, Boolean isStdErr) { Path projectWorkingDirectory = projectDir == null ? commands.getWorkingDirectory() : commands.getWorkingDirectory().resolve(projectDir.as(runContext, String.class)); - String profilesString = profiles.as(runContext, String.class); + String profilesString = profiles == null ? null : profiles.as(runContext, String.class); if (profilesString != null && !profilesString.isEmpty()) { var profileFile = new File(commands.getWorkingDirectory().toString(), "profiles.yml"); if (profileFile.exists()) { diff --git a/src/main/java/io/kestra/plugin/dbt/cloud/CheckStatus.java b/src/main/java/io/kestra/plugin/dbt/cloud/CheckStatus.java index 0a17802..50e4dbe 100644 --- a/src/main/java/io/kestra/plugin/dbt/cloud/CheckStatus.java +++ b/src/main/java/io/kestra/plugin/dbt/cloud/CheckStatus.java @@ -16,6 +16,7 @@ import io.micronaut.http.HttpRequest; import io.micronaut.http.uri.UriTemplate; import io.swagger.v3.oas.annotations.media.Schema; +import jakarta.validation.constraints.NotNull; import lombok.*; import lombok.experimental.SuperBuilder; import org.slf4j.Logger; @@ -69,6 +70,7 @@ public class CheckStatus extends AbstractDbtCloud implements RunnableTask runId;