diff options
author | jonmv <venstad@gmail.com> | 2022-04-09 19:45:59 +0200 |
---|---|---|
committer | jonmv <venstad@gmail.com> | 2022-04-09 19:45:59 +0200 |
commit | fc3a845edb740128ad693ecea064370ded758dfa (patch) | |
tree | 3319c26cd06188508a11bce64512422d9694f4f1 | |
parent | 5a97276296b1eef076b90b6858706a3720591e96 (diff) |
* Actually prune dev diffs -- they are counted per job now
-rw-r--r-- | controller-server/src/main/java/com/yahoo/vespa/hosted/controller/deployment/JobController.java | 22 |
1 files changed, 9 insertions, 13 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/deployment/JobController.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/deployment/JobController.java index ab251c4f46d..b1a9f3abdd4 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/deployment/JobController.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/deployment/JobController.java @@ -422,19 +422,15 @@ public class JobController { logs.flush(id); metric.jobFinished(run.id().job(), finishedRun.status()); - DeploymentId deploymentId = new DeploymentId(unlockedRun.id().application(), unlockedRun.id().job().type().zone(controller.system())); - (unlockedRun.versions().targetApplication().isDeployedDirectly() ? - Stream.of(unlockedRun.id().type()) : - JobType.allIn(controller.system()).stream().filter(jobType -> !jobType.environment().isManuallyDeployed())) - .flatMap(jobType -> controller.jobController().runs(unlockedRun.id().application(), jobType).values().stream()) - .mapToLong(r -> r.versions().targetApplication().buildNumber().orElse(Integer.MAX_VALUE)) - .min() - .ifPresent(oldestBuild -> { - if (unlockedRun.versions().targetApplication().isDeployedDirectly()) - controller.applications().applicationStore().pruneDevDiffs(deploymentId, oldestBuild); - else - controller.applications().applicationStore().pruneDiffs(deploymentId.applicationId().tenant(), deploymentId.applicationId().application(), oldestBuild); - }); + controller.jobController().runs(id.job()).values().stream() + .mapToLong(r -> r.versions().targetApplication().buildNumber().orElse(Integer.MAX_VALUE)) + .min() + .ifPresent(oldestBuild -> { + if (unlockedRun.versions().targetApplication().isDeployedDirectly()) + controller.applications().applicationStore().pruneDevDiffs(new DeploymentId(id.application(), id.job().type().zone(controller.system())), oldestBuild); + else + controller.applications().applicationStore().pruneDiffs(id.application().tenant(), id.application().application(), oldestBuild); + }); return finishedRun; }); } |