From f23c12ecba37df5f8bf23ba895b5adaa4716fd3a Mon Sep 17 00:00:00 2001 From: hideki narimiya Date: Wed, 19 Jan 2022 17:44:38 +0900 Subject: [PATCH] Fixed to remove k8s pod on finished --- .../io/digdag/standards/command/KubernetesCommandExecutor.java | 1 + 1 file changed, 1 insertion(+) diff --git a/digdag-standards/src/main/java/io/digdag/standards/command/KubernetesCommandExecutor.java b/digdag-standards/src/main/java/io/digdag/standards/command/KubernetesCommandExecutor.java index 872927484c..93e744067c 100644 --- a/digdag-standards/src/main/java/io/digdag/standards/command/KubernetesCommandExecutor.java +++ b/digdag-standards/src/main/java/io/digdag/standards/command/KubernetesCommandExecutor.java @@ -275,6 +275,7 @@ CommandStatus getCommandStatusFromKubernetes(final CommandContext context, // Download output config archive final InputStream in = outConfigStorage.getContentInputStream(outputArchiveKey); ProjectArchives.extractTarArchive(context.getLocalProjectPath(), in); // runtime exception + client.deletePod(pod.getName()); } else if (defaultPodTTL.isPresent() && isRunningLongerThanTTL(previousStatusJson)) { TaskRequest request = context.getTaskRequest();