summaryrefslogtreecommitdiffstats
path: root/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/application/DeploymentJobs.java
diff options
context:
space:
mode:
Diffstat (limited to 'controller-server/src/main/java/com/yahoo/vespa/hosted/controller/application/DeploymentJobs.java')
-rw-r--r--controller-server/src/main/java/com/yahoo/vespa/hosted/controller/application/DeploymentJobs.java31
1 files changed, 12 insertions, 19 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/application/DeploymentJobs.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/application/DeploymentJobs.java
index b4ca00243b7..722e8d10f40 100644
--- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/application/DeploymentJobs.java
+++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/application/DeploymentJobs.java
@@ -31,25 +31,23 @@ public class DeploymentJobs {
private final Optional<Long> projectId;
private final ImmutableMap<JobType, JobStatus> status;
private final Optional<String> jiraIssueId;
- private final boolean selfTriggering; // TODO: Remove this when no projects are self-triggering.
/** Creates an empty set of deployment jobs */
public DeploymentJobs(long projectId) {
- this(Optional.of(projectId), ImmutableMap.of(), Optional.empty(),true);
+ this(Optional.of(projectId), ImmutableMap.of(), Optional.empty());
}
- public DeploymentJobs(Optional<Long> projectId, Collection<JobStatus> jobStatusEntries, Optional<String> jiraIssueId, boolean selfTriggering) {
- this(projectId, asMap(jobStatusEntries), jiraIssueId, selfTriggering);
+ public DeploymentJobs(Optional<Long> projectId, Collection<JobStatus> jobStatusEntries, Optional<String> jiraIssueId) {
+ this(projectId, asMap(jobStatusEntries), jiraIssueId);
}
- private DeploymentJobs(Optional<Long> projectId, Map<JobType, JobStatus> status, Optional<String> jiraIssueId, boolean selfTriggering) {
+ private DeploymentJobs(Optional<Long> projectId, Map<JobType, JobStatus> status, Optional<String> jiraIssueId) {
Objects.requireNonNull(projectId, "projectId cannot be null");
Objects.requireNonNull(status, "status cannot be null");
Objects.requireNonNull(jiraIssueId, "jiraIssueId cannot be null");
this.projectId = projectId;
this.status = ImmutableMap.copyOf(status);
this.jiraIssueId = jiraIssueId;
- this.selfTriggering = selfTriggering;
}
private static Map<JobType, JobStatus> asMap(Collection<JobStatus> jobStatusEntries) {
@@ -66,7 +64,7 @@ public class DeploymentJobs {
if (job == null) job = JobStatus.initial(report.jobType());
return job.withCompletion(report.jobError(), notificationTime, controller);
});
- return new DeploymentJobs(Optional.of(report.projectId()), status, jiraIssueId, report.selfTriggering());
+ return new DeploymentJobs(Optional.of(report.projectId()), status, jiraIssueId);
}
public DeploymentJobs withTriggering(JobType jobType,
@@ -81,33 +79,30 @@ public class DeploymentJobs {
change.isPresent() && change.get() instanceof Change.VersionChange,
triggerTime);
});
- return new DeploymentJobs(projectId, status, jiraIssueId, selfTriggering);
+ return new DeploymentJobs(projectId, status, jiraIssueId);
}
public DeploymentJobs withProjectId(long projectId) {
- return new DeploymentJobs(Optional.of(projectId), status, jiraIssueId, selfTriggering);
+ return new DeploymentJobs(Optional.of(projectId), status, jiraIssueId);
}
public DeploymentJobs withJiraIssueId(Optional<String> jiraIssueId) {
- return new DeploymentJobs(projectId, status, jiraIssueId, selfTriggering);
+ return new DeploymentJobs(projectId, status, jiraIssueId);
}
public DeploymentJobs without(JobType job) {
Map<JobType, JobStatus> status = new HashMap<>(this.status);
status.remove(job);
- return new DeploymentJobs(projectId, status, jiraIssueId, selfTriggering);
+ return new DeploymentJobs(projectId, status, jiraIssueId);
}
public DeploymentJobs asSelfTriggering(boolean selfTriggering) {
- return new DeploymentJobs(projectId, status, jiraIssueId, selfTriggering);
+ return new DeploymentJobs(projectId, status, jiraIssueId);
}
/** Returns an immutable map of the status entries in this */
public Map<JobType, JobStatus> jobStatus() { return status; }
- /** Returns whether this application's deployment jobs trigger each other, and should be left alone, or not. */
- public boolean isSelfTriggering() { return selfTriggering; }
-
/** Returns whether this has some job status which is not a success */
public boolean hasFailures() {
return status.values().stream().anyMatch(jobStatus -> ! jobStatus.isSuccess());
@@ -281,19 +276,18 @@ public class DeploymentJobs {
private final long projectId;
private final long buildNumber;
private final Optional<JobError> jobError;
- private final boolean selfTriggering;
public JobReport(ApplicationId applicationId, JobType jobType, long projectId, long buildNumber,
- Optional<JobError> jobError, boolean selfTriggering) {
+ Optional<JobError> jobError) {
Objects.requireNonNull(applicationId, "applicationId cannot be null");
Objects.requireNonNull(jobType, "jobType cannot be null");
Objects.requireNonNull(jobError, "jobError cannot be null");
+
this.applicationId = applicationId;
this.projectId = projectId;
this.buildNumber = buildNumber;
this.jobType = jobType;
this.jobError = jobError;
- this.selfTriggering = selfTriggering;
}
public ApplicationId applicationId() { return applicationId; }
@@ -302,7 +296,6 @@ public class DeploymentJobs {
public long buildNumber() { return buildNumber; }
public boolean success() { return !jobError.isPresent(); }
public Optional<JobError> jobError() { return jobError; }
- public boolean selfTriggering() { return selfTriggering; }
}