Fixed to remove k8s pod on finished (#1696)

treasure-data · Jul 5, 2022 · 1f26387 · 1f26387
1 parent 81367ae
commit 1f26387
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -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();