summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorJon Marius Venstad <venstad@gmail.com>2017-11-15 13:23:26 +0100
committerJon Marius Venstad <venstad@gmail.com>2017-11-15 13:23:26 +0100
commit62648792b3be4bc065e223673c8ee818f488e6e2 (patch)
treeeec94824e2636c7715436a2c8478a574ece94472
parenteebbf1d8fbd9a01fee599fe160abe6212f1ccfbf (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.java22
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 */