jprdonnelly/kestra
1
0
Fork 0
mirror of https://github.com/kestra-io/kestra.git synced 2025-12-19 18:05:41 -05:00
Code Issues Packages Projects Releases Wiki Activity

feat(scripts): enable script/cli plugins to override final task state

Browse Source
This commit is contained in:
Malaydewangan09
2025-06-23 15:51:42 +05:30
committed by Malay Dewangan
parent 076ae2e933
commit a1e53443a5
2 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
script/src/main/java/io/kestra/plugin/scripts/exec/AbstractExecScript.java
View File

@@ -10,7 +10,6 @@ import io.kestra.core.runners.RunContext;
import io.kestra.plugin.core.runner.Process;
import io.kestra.plugin.scripts.exec.scripts.models.DockerOptions;
import io.kestra.plugin.scripts.exec.scripts.models.RunnerType;
import io.kestra.plugin.scripts.exec.scripts.models.ScriptOutput;
import io.kestra.plugin.scripts.exec.scripts.runners.CommandsWrapper;
import io.kestra.plugin.scripts.runner.docker.Docker;
import io.kestra.plugin.scripts.runner.docker.PullPolicy;
@@ -32,7 +31,7 @@ import java.util.Map;
@EqualsAndHashCode
@Getter
@NoArgsConstructor
public abstract class AbstractExecScript extends Task implements RunnableTask<ScriptOutput>, NamespaceFilesInterface, InputFilesInterface, OutputFilesInterface {
public abstract class AbstractExecScript extends Task implements NamespaceFilesInterface, InputFilesInterface, OutputFilesInterface {
@Schema(
title = "Deprecated - use the 'taskRunner' property instead.",
description = "Only used if the `taskRunner` property is not set",
@@ -208,8 +207,6 @@ public abstract class AbstractExecScript extends Task implements RunnableTask<Sc
return List.of("set -e");
}
/** {@inheritDoc} **/
@Override
public void kill() {
if (this.getTaskRunner() != null) {
this.getTaskRunner().kill();

4
script/src/main/java/io/kestra/plugin/scripts/exec/scripts/models/ScriptOutput.java
View File

@@ -6,14 +6,14 @@ import io.kestra.core.models.annotations.PluginProperty;
import io.kestra.core.models.tasks.Output;
import io.kestra.core.models.tasks.runners.TaskRunnerDetailResult;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Builder;
import lombok.Getter;
import java.net.URI;
import java.util.Map;
import jakarta.validation.constraints.NotNull;
import lombok.experimental.SuperBuilder;
@Builder
@SuperBuilder
@Getter
public class ScriptOutput implements Output {
@Schema(