Skip to content
This repository was archived by the owner on Feb 13, 2026. It is now read-only.

Commit ee91aca

Browse files
author
Mathieu Gabelle
committed
fix: commands wrapper dp
1 parent bb45c62 commit ee91aca

File tree

1 file changed

+4
-6
lines changed

1 file changed

+4
-6
lines changed

src/main/java/io/kestra/plugin/singer/AbstractPythonSinger.java

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -142,14 +142,12 @@ protected void run(RunContext runContext, String command, AbstractLogConsumer lo
142142
.withTaskRunner(taskRunner)
143143
.withContainerImage(runContext.render(this.containerImage).as(String.class).orElseThrow())
144144
.withLogConsumer(logConsumer)
145-
.withCommands(ScriptService.scriptCommands(
146-
List.of("/bin/sh", "-c"),
147-
Stream.of(
145+
.withInterpreter(Property.of(List.of("/bin/sh", "-c")))
146+
.withBeforeCommands(Property.of(Stream.of(
148147
pipInstallCommands(runContext),
149148
logSetupCommands()
150-
).flatMap(Function.identity()).toList(),
151-
List.of(command)
152-
))
149+
).flatMap(Function.identity()).toList()))
150+
.withCommands(Property.of(List.of(command)))
153151
.withEnv(this.environmentVariables(runContext))
154152
.run();
155153
}

0 commit comments

Comments
 (0)