diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2017-11-15 13:23:26 +0100 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2017-11-15 13:23:26 +0100 |
commit | 62648792b3be4bc065e223673c8ee818f488e6e2 (patch) | |
tree | eec94824e2636c7715436a2c8478a574ece94472 | |
parent | eebbf1d8fbd9a01fee599fe160abe6212f1ccfbf (diff) |
The only job we should trigger, without a zone, is component, on retries
-rw-r--r-- | controller-server/src/main/java/com/yahoo/vespa/hosted/controller/LockedApplication.java | 22 |
1 files changed, 10 insertions, 12 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/LockedApplication.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/LockedApplication.java index 56b76260f14..2954f910a4e 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/LockedApplication.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/LockedApplication.java @@ -10,6 +10,7 @@ import com.yahoo.vespa.hosted.controller.application.ApplicationRevision; import com.yahoo.vespa.hosted.controller.application.Change; import com.yahoo.vespa.hosted.controller.application.Deployment; import com.yahoo.vespa.hosted.controller.application.DeploymentJobs; +import com.yahoo.vespa.hosted.controller.application.DeploymentJobs.JobType; import java.time.Instant; import java.util.LinkedHashMap; @@ -127,18 +128,15 @@ public class LockedApplication extends Application { } private Version determineTriggerVersion(DeploymentJobs.JobType jobType, Controller controller) { - Optional<Zone> zone = jobType.zone(controller.system()); - if ( ! zone.isPresent()) // a sloppy test TODO: Fix - return controller.systemVersion(); - return currentDeployVersion(controller, zone.get()); - } - - private Optional<ApplicationRevision> determineTriggerRevision(DeploymentJobs.JobType jobType, - Controller controller) { - Optional<Zone> zone = jobType.zone(controller.system()); - if ( ! zone.isPresent()) // a sloppy test TODO: Fix - return Optional.empty(); - return currentDeployRevision(jobType.zone(controller.system()).get()); + return jobType == JobType.component + ? controller.systemVersion() + : currentDeployVersion(controller, jobType.zone(controller.system()).get()); + } + + private Optional<ApplicationRevision> determineTriggerRevision(DeploymentJobs.JobType jobType, Controller controller) { + return jobType == JobType.component + ? Optional.empty() + : currentDeployRevision(jobType.zone(controller.system()).get()); } /** Returns the version a deployment to this zone should use for this application, or empty if we don't know */ |