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(script): add privileged flags to docker

Browse Source
This commit is contained in:
Ludovic DEHON
2025-01-03 16:48:44 +01:00
parent e1c202a3cb
commit e8ee97e26d
2 changed files with 17 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
script/src/main/java/io/kestra/plugin/scripts/exec/scripts/models/DockerOptions.java
View File

@@ -113,6 +113,12 @@ public class DockerOptions {
@PluginProperty(dynamic = true)
private String shmSize;
@Schema(
title = "Give extended privileges to this container."
)
@PluginProperty(dynamic = true)
private Boolean privileged;
@Deprecated
public void setDockerHost(String host) {
this.host = host;

11
script/src/main/java/io/kestra/plugin/scripts/runner/docker/Docker.java
View File

@@ -264,6 +264,12 @@ public class Docker extends TaskRunner {
@PluginProperty(dynamic = true)
private String shmSize;
@Schema(
title = "Give extended privileges to this container."
)
@PluginProperty(dynamic = true)
private Boolean privileged;
@Schema(
title = "File handling strategy.",
description = """
@@ -312,6 +318,7 @@ public class Docker extends TaskRunner {
.cpu(dockerOptions.getCpu())
.memory(dockerOptions.getMemory())
.shmSize(dockerOptions.getShmSize())
.privileged(dockerOptions.getPrivileged())
.build();
}
@@ -729,6 +736,10 @@ public class Docker extends TaskRunner {
hostConfig.withShmSize(convertBytes(runContext.render(this.getShmSize())));
}
if (this.getPrivileged() != null) {
hostConfig.withPrivileged(this.getPrivileged());
}
if (this.getNetworkMode() != null) {
hostConfig.withNetworkMode(runContext.render(this.getNetworkMode(), additionalVars));
}