refactor(*): implement RunnableTask interface

Malaydewangan09 · Malaydewangan09 · commit 397e50abbf87 · 2025-06-26T16:46:58.000+05:30
diff --git a/plugin-script-bun/src/main/java/io/kestra/plugin/scripts/bun/Commands.java b/plugin-script-bun/src/main/java/io/kestra/plugin/scripts/bun/Commands.java
@@ -4,6 +4,7 @@
 import io.kestra.core.models.annotations.Example;
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.RunContext;
 import io.kestra.plugin.scripts.exec.AbstractExecScript;
@@ -61,7 +62,7 @@
             """
     )
 })
-public class Commands extends AbstractExecScript {
+public class Commands extends AbstractExecScript implements RunnableTask<ScriptOutput> {
     private static final String DEFAULT_IMAGE = "oven/bun";
 
     @Builder.Default
diff --git a/plugin-script-bun/src/main/java/io/kestra/plugin/scripts/bun/Script.java b/plugin-script-bun/src/main/java/io/kestra/plugin/scripts/bun/Script.java
@@ -4,6 +4,7 @@
 import io.kestra.core.models.annotations.Example;
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.FilesService;
 import io.kestra.core.runners.RunContext;
@@ -67,7 +68,7 @@
     ),
 
 })
-public class Script extends AbstractExecScript {
+public class Script extends AbstractExecScript implements RunnableTask<ScriptOutput> {
     private static final String DEFAULT_IMAGE = "oven/bun";
 
     @Builder.Default
diff --git a/plugin-script-deno/src/main/java/io/kestra/plugin/scripts/deno/Commands.java b/plugin-script-deno/src/main/java/io/kestra/plugin/scripts/deno/Commands.java
@@ -3,6 +3,7 @@
 import io.kestra.core.models.annotations.Example;
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.RunContext;
 import io.kestra.plugin.scripts.exec.AbstractExecScript;
@@ -42,7 +43,7 @@
             """
     )
 })
-public class Commands extends AbstractExecScript {
+public class Commands extends AbstractExecScript implements RunnableTask<ScriptOutput> {
     private static final String DEFAULT_IMAGE = "denoland/deno";
 
     @Builder.Default
diff --git a/plugin-script-deno/src/main/java/io/kestra/plugin/scripts/deno/Script.java b/plugin-script-deno/src/main/java/io/kestra/plugin/scripts/deno/Script.java
@@ -4,6 +4,7 @@
 import io.kestra.core.models.annotations.Example;
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.FilesService;
 import io.kestra.core.runners.RunContext;
@@ -41,7 +42,7 @@
             """
     ),
 })
-public class Script extends AbstractExecScript {
+public class Script extends AbstractExecScript implements RunnableTask<ScriptOutput> {
     private static final String DEFAULT_IMAGE = "denoland/deno";
 
     @Builder.Default
diff --git a/plugin-script-go/src/main/java/io/kestra/plugin/scripts/go/Commands.java b/plugin-script-go/src/main/java/io/kestra/plugin/scripts/go/Commands.java
@@ -4,6 +4,7 @@
 import io.kestra.core.models.annotations.Example;
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.RunContext;
 import io.kestra.plugin.scripts.exec.AbstractExecScript;
@@ -63,7 +64,7 @@ func main() {
             """
     )
 })
-public class Commands extends AbstractExecScript {
+public class Commands extends AbstractExecScript implements RunnableTask<ScriptOutput> {
     private static final String DEFAULT_IMAGE = "golang";
 
     @Builder.Default
diff --git a/plugin-script-go/src/main/java/io/kestra/plugin/scripts/go/Script.java b/plugin-script-go/src/main/java/io/kestra/plugin/scripts/go/Script.java
@@ -4,6 +4,7 @@
 import io.kestra.core.models.annotations.Example;
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.FilesService;
 import io.kestra.core.runners.RunContext;
@@ -61,7 +62,7 @@ func main() {
             """
     )
 })
-public class Script extends AbstractExecScript {
+public class Script extends AbstractExecScript implements RunnableTask<ScriptOutput> {
     private static final String DEFAULT_IMAGE = "golang";
 
     @Builder.Default
diff --git a/plugin-script-jbang/src/main/java/io/kestra/plugin/scripts/jbang/Commands.java b/plugin-script-jbang/src/main/java/io/kestra/plugin/scripts/jbang/Commands.java
@@ -5,6 +5,7 @@
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.annotations.PluginProperty;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.ScriptService;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.RunContext;
@@ -45,7 +46,7 @@
         )
     }
 )
-public class Commands extends AbstractExecScript {
+public class Commands extends AbstractExecScript implements RunnableTask<ScriptOutput> {
     private static final String DEFAULT_IMAGE = "jbangdev/jbang-action";
 
     @Builder.Default
diff --git a/plugin-script-jbang/src/main/java/io/kestra/plugin/scripts/jbang/Script.java b/plugin-script-jbang/src/main/java/io/kestra/plugin/scripts/jbang/Script.java
@@ -5,6 +5,7 @@
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.annotations.PluginProperty;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.ScriptService;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.FilesService;
@@ -104,7 +105,7 @@ public fun main() {
         )
     }
 )
-public class Script extends AbstractExecScript {
+public class Script extends AbstractExecScript implements RunnableTask<ScriptOutput> {
     private static final String DEFAULT_IMAGE = "jbangdev/jbang-action";
 
     @Builder.Default
diff --git a/plugin-script-julia/src/main/java/io/kestra/plugin/scripts/julia/Commands.java b/plugin-script-julia/src/main/java/io/kestra/plugin/scripts/julia/Commands.java
@@ -5,6 +5,7 @@
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.annotations.PluginProperty;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.ScriptService;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.RunContext;
@@ -52,7 +53,7 @@
             """
     )
 })
-public class Commands extends AbstractExecScript {
+public class Commands extends AbstractExecScript implements RunnableTask<ScriptOutput> {
     private static final String DEFAULT_IMAGE = "julia";
 
     @Builder.Default
diff --git a/plugin-script-julia/src/main/java/io/kestra/plugin/scripts/julia/Script.java b/plugin-script-julia/src/main/java/io/kestra/plugin/scripts/julia/Script.java
@@ -5,6 +5,7 @@
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.annotations.PluginProperty;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.ScriptService;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.FilesService;
@@ -54,7 +55,7 @@
             """
     )
 })
-public class Script extends AbstractExecScript {
+public class Script extends AbstractExecScript implements RunnableTask<ScriptOutput> {
     private static final String DEFAULT_IMAGE = "julia";
 
     @Builder.Default
diff --git a/plugin-script-lua/src/main/java/io/kestra/plugin/scripts/lua/Commands.java b/plugin-script-lua/src/main/java/io/kestra/plugin/scripts/lua/Commands.java
@@ -3,6 +3,7 @@
 import io.kestra.core.models.annotations.Example;
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.RunContext;
 import io.kestra.plugin.scripts.exec.AbstractExecScript;
@@ -33,7 +34,7 @@
             """
     )
 })
-public class Commands extends AbstractExecScript {
+public class Commands extends AbstractExecScript implements RunnableTask<ScriptOutput> {
     private static final String DEFAULT_IMAGE = "nickblah/lua";
 
     @Builder.Default
diff --git a/plugin-script-lua/src/main/java/io/kestra/plugin/scripts/lua/Script.java b/plugin-script-lua/src/main/java/io/kestra/plugin/scripts/lua/Script.java
@@ -4,6 +4,7 @@
 import io.kestra.core.models.annotations.Example;
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.FilesService;
 import io.kestra.core.runners.RunContext;
@@ -42,7 +43,7 @@
             """
     ),
 })
-public class Script extends AbstractExecScript {
+public class Script extends AbstractExecScript implements RunnableTask<ScriptOutput> {
     private static final String DEFAULT_IMAGE = "nickblah/lua";
 
     @Builder.Default
diff --git a/plugin-script-node/src/main/java/io/kestra/plugin/scripts/node/Commands.java b/plugin-script-node/src/main/java/io/kestra/plugin/scripts/node/Commands.java
@@ -5,6 +5,7 @@
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.annotations.PluginProperty;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.ScriptService;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.RunContext;
@@ -50,7 +51,7 @@
             """
     )
 })
-public class Commands extends AbstractExecScript {
+public class Commands extends AbstractExecScript implements RunnableTask<ScriptOutput> {
     private static final String DEFAULT_IMAGE = "node";
 
     @Builder.Default
diff --git a/plugin-script-node/src/main/java/io/kestra/plugin/scripts/node/Script.java b/plugin-script-node/src/main/java/io/kestra/plugin/scripts/node/Script.java
@@ -5,6 +5,7 @@
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.annotations.PluginProperty;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.ScriptService;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.FilesService;
@@ -166,7 +167,7 @@
             """
     )
 })
-public class Script extends AbstractExecScript {
+public class Script extends AbstractExecScript implements RunnableTask<ScriptOutput> {
     private static final String DEFAULT_IMAGE = "node";
 
     @Builder.Default
diff --git a/plugin-script-perl/src/main/java/io/kestra/plugin/scripts/perl/Commands.java b/plugin-script-perl/src/main/java/io/kestra/plugin/scripts/perl/Commands.java
@@ -3,6 +3,7 @@
 import io.kestra.core.models.annotations.Example;
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.RunContext;
 import io.kestra.plugin.scripts.exec.AbstractExecScript;
@@ -33,7 +34,7 @@
             """
     )
 })
-public class Commands extends AbstractExecScript {
+public class Commands extends AbstractExecScript implements RunnableTask<ScriptOutput> {
     private static final String DEFAULT_IMAGE = "perl";
 
     @Builder.Default
diff --git a/plugin-script-perl/src/main/java/io/kestra/plugin/scripts/perl/Script.java b/plugin-script-perl/src/main/java/io/kestra/plugin/scripts/perl/Script.java
@@ -4,6 +4,7 @@
 import io.kestra.core.models.annotations.Example;
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.FilesService;
 import io.kestra.core.runners.RunContext;
@@ -42,7 +43,7 @@
             """
     ),
 })
-public class Script extends AbstractExecScript {
+public class Script extends AbstractExecScript implements RunnableTask<ScriptOutput> {
     private static final String DEFAULT_IMAGE = "perl";
 
     @Builder.Default
diff --git a/plugin-script-php/src/main/java/io/kestra/plugin/scripts/php/Commands.java b/plugin-script-php/src/main/java/io/kestra/plugin/scripts/php/Commands.java
@@ -4,6 +4,7 @@
 import io.kestra.core.models.annotations.Example;
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.RunContext;
 import io.kestra.plugin.scripts.exec.AbstractExecScript;
@@ -47,7 +48,7 @@
             """
     )
 })
-public class Commands extends AbstractExecScript {
+public class Commands extends AbstractExecScript implements RunnableTask<ScriptOutput> {
     private static final String DEFAULT_IMAGE = "php";
 
     @Builder.Default
diff --git a/plugin-script-php/src/main/java/io/kestra/plugin/scripts/php/Script.java b/plugin-script-php/src/main/java/io/kestra/plugin/scripts/php/Script.java
@@ -4,6 +4,7 @@
 import io.kestra.core.models.annotations.Example;
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.FilesService;
 import io.kestra.core.runners.RunContext;
@@ -47,7 +48,7 @@
             """
     ),
 })
-public class Script extends AbstractExecScript {
+public class Script extends AbstractExecScript implements RunnableTask<ScriptOutput> {
     private static final String DEFAULT_IMAGE = "php";
 
     @Builder.Default
diff --git a/plugin-script-powershell/src/main/java/io/kestra/plugin/scripts/powershell/Commands.java b/plugin-script-powershell/src/main/java/io/kestra/plugin/scripts/powershell/Commands.java
@@ -5,6 +5,7 @@
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.annotations.PluginProperty;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.ScriptService;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.RunContext;
@@ -48,7 +49,7 @@
             """
     )
 })
-public class Commands extends AbstractExecScript {
+public class Commands extends AbstractExecScript implements RunnableTask<ScriptOutput> {
     private static final String DEFAULT_IMAGE = "ghcr.io/kestra-io/powershell:latest";
 
     @Builder.Default
diff --git a/plugin-script-powershell/src/main/java/io/kestra/plugin/scripts/powershell/Script.java b/plugin-script-powershell/src/main/java/io/kestra/plugin/scripts/powershell/Script.java
@@ -5,6 +5,7 @@
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.annotations.PluginProperty;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.ScriptService;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.FilesService;
@@ -66,7 +67,7 @@
         )
     }
 )
-public class Script extends AbstractExecScript {
+public class Script extends AbstractExecScript implements RunnableTask<ScriptOutput> {
     private static final String DEFAULT_IMAGE = "ghcr.io/kestra-io/powershell:latest";
 
     @Builder.Default
diff --git a/plugin-script-python/src/main/java/io/kestra/plugin/scripts/python/Commands.java b/plugin-script-python/src/main/java/io/kestra/plugin/scripts/python/Commands.java
@@ -4,6 +4,7 @@
 import io.kestra.core.models.annotations.Example;
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.RunContext;
 import io.kestra.plugin.scripts.exec.scripts.models.DockerOptions;
@@ -57,7 +58,7 @@
         code = """
               id: python_venv
               namespace: company.team
-              
+
               inputs:
                 - id: nr
                   type: INT
@@ -74,7 +75,7 @@
                     type: io.kestra.plugin.core.runner.Process
                   beforeCommands:
                     - uv venv --python 3.13
-                    - uv pip install requests                    
+                    - uv pip install requests
                   commands:
                     - python etl_script.py --num {{inputs.nr}}
               """
@@ -280,7 +281,7 @@
             """
     )
 })
-public class Commands extends AbstractPythonExecScript {
+public class Commands extends AbstractPythonExecScript implements RunnableTask<ScriptOutput> {
 
     @Schema(
         title = "The commands to run."
diff --git a/plugin-script-python/src/main/java/io/kestra/plugin/scripts/python/Script.java b/plugin-script-python/src/main/java/io/kestra/plugin/scripts/python/Script.java
@@ -4,6 +4,7 @@
 import io.kestra.core.models.annotations.Example;
 import io.kestra.core.models.annotations.Plugin;
 import io.kestra.core.models.property.Property;
+import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.models.tasks.runners.TargetOS;
 import io.kestra.core.runners.FilesService;
 import io.kestra.core.runners.RunContext;
@@ -288,7 +289,7 @@ with open('{{ outputs.download.uri }}', 'r') as f:
         )
     }
 )
-public class Script extends AbstractPythonExecScript {
+public class Script extends AbstractPythonExecScript implements RunnableTask<ScriptOutput> {
 
     @Schema(
         title = "The inline script content. This property is intended for the script file's content as a (multiline) string, not a path to a file. To run a command from a file such as `bash myscript.sh` or `python myscript.py`, use the `Commands` task instead."
diff --git a/plugin-script-r/src/main/java/io/kestra/plugin/scripts/r/Commands.java b/plugin-script-r/src/main/java/io/kestra/plugin/scripts/r/Commands.java
diff --git a/plugin-script-r/src/main/java/io/kestra/plugin/scripts/r/Script.java b/plugin-script-r/src/main/java/io/kestra/plugin/scripts/r/Script.java
diff --git a/plugin-script-ruby/src/main/java/io/kestra/plugin/scripts/ruby/Commands.java b/plugin-script-ruby/src/main/java/io/kestra/plugin/scripts/ruby/Commands.java
diff --git a/plugin-script-ruby/src/main/java/io/kestra/plugin/scripts/ruby/Script.java b/plugin-script-ruby/src/main/java/io/kestra/plugin/scripts/ruby/Script.java
diff --git a/plugin-script-shell/src/main/java/io/kestra/plugin/scripts/shell/Commands.java b/plugin-script-shell/src/main/java/io/kestra/plugin/scripts/shell/Commands.java
diff --git a/plugin-script-shell/src/main/java/io/kestra/plugin/scripts/shell/Script.java b/plugin-script-shell/src/main/java/io/kestra/plugin/scripts/shell/Script.java

Original file line number	Diff line number	Diff line change
`@@ -5,6 +5,7 @@`
`5`	`5`	`import io.kestra.core.models.annotations.Plugin;`
`6`	`6`	`import io.kestra.core.models.annotations.PluginProperty;`
`7`	`7`	`import io.kestra.core.models.property.Property;`
	`8`	`+import io.kestra.core.models.tasks.RunnableTask;`
`8`	`9`	`import io.kestra.core.models.tasks.runners.ScriptService;`
`9`	`10`	`import io.kestra.core.models.tasks.runners.TargetOS;`
`10`	`11`	`import io.kestra.core.runners.RunContext;`
`@@ -45,7 +46,7 @@`
`45`	`46`	`)`
`46`	`47`	`}`
`47`	`48`	`)`
`48`		`-public class Commands extends AbstractExecScript {`
	`49`	`+public class Commands extends AbstractExecScript implements RunnableTask<ScriptOutput> {`
`49`	`50`	`private static final String DEFAULT_IMAGE = "jbangdev/jbang-action";`
`50`	`51`
`51`	`52`	`@Builder.Default`