44import io .kestra .core .models .annotations .Example ;
55import io .kestra .core .models .annotations .Plugin ;
66import io .kestra .core .models .annotations .PluginProperty ;
7+ import io .kestra .core .models .property .Property ;
78import io .kestra .core .models .tasks .runners .ScriptService ;
89import io .kestra .core .models .tasks .*;
910import io .kestra .core .models .tasks .runners .TaskRunner ;
@@ -139,7 +140,7 @@ public class AwsCLI extends AbstractConnection implements RunnableTask<ScriptOut
139140
140141 private Object inputFiles ;
141142
142- private List <String > outputFiles ;
143+ private Property < List <String > > outputFiles ;
143144
144145 private CredentialSource stsCredentialSource ;
145146
@@ -168,6 +169,8 @@ public ScriptOutput run(RunContext runContext) throws Exception {
168169 allCommands .add ("aws configure set credential_source " + this .stsCredentialSource .value );
169170 }
170171
172+ var renderedOutputFiles = runContext .render (outputFiles ).asList (String .class );
173+
171174 CommandsWrapper commands = new CommandsWrapper (runContext )
172175 .withWarningOnStdErr (true )
173176 .withDockerOptions (injectDefaults (getDocker ()))
@@ -182,7 +185,7 @@ public ScriptOutput run(RunContext runContext) throws Exception {
182185 .withEnv (this .getEnv (runContext ))
183186 .withNamespaceFiles (namespaceFiles )
184187 .withInputFiles (inputFiles )
185- .withOutputFiles (outputFiles );
188+ .withOutputFiles (renderedOutputFiles . isEmpty () ? null : renderedOutputFiles );
186189
187190 return commands .run ();
188191 }
0 commit comments