Skip to content

Commit 1a4b6af

Browse files
committed
feat: deprecate DefaultLogConsumer as it moved to core
1 parent 960c552 commit 1a4b6af

2 files changed

Lines changed: 7 additions & 19 deletions

File tree

plugin-script/src/main/java/io/kestra/plugin/scripts/exec/scripts/runners/CommandsWrapper.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22

33
import io.kestra.core.exceptions.IllegalVariableEvaluationException;
44
import io.kestra.core.models.script.*;
5+
import io.kestra.core.models.script.DefaultLogConsumer;
56
import io.kestra.core.models.script.types.ProcessScriptRunner;
67
import io.kestra.core.models.tasks.NamespaceFiles;
78
import io.kestra.core.runners.FilesService;
Lines changed: 6 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -1,26 +1,13 @@
11
package io.kestra.plugin.scripts.exec.scripts.runners;
22

3-
import io.kestra.core.models.script.AbstractLogConsumer;
43
import io.kestra.core.runners.RunContext;
5-
import io.kestra.core.tasks.PluginUtilsService;
6-
7-
public class DefaultLogConsumer extends AbstractLogConsumer {
8-
private final RunContext runContext;
94

5+
/**
6+
* Use io.kestra.core.models.script.DefaultLogConsumer instead
7+
*/
8+
@Deprecated
9+
public class DefaultLogConsumer extends io.kestra.core.models.script.DefaultLogConsumer {
1010
public DefaultLogConsumer(RunContext runContext) {
11-
this.runContext = runContext;
12-
}
13-
14-
@Override
15-
public void accept(String line, Boolean isStdErr) {
16-
outputs.putAll(PluginUtilsService.parseOut(line, runContext.logger(), runContext));
17-
18-
if (isStdErr) {
19-
this.stdErrCount.incrementAndGet();
20-
runContext.logger().warn(line);
21-
} else {
22-
this.stdOutCount.incrementAndGet();
23-
runContext.logger().info(line);
24-
}
11+
super(runContext);
2512
}
2613
}

0 commit comments

Comments
 (0)