Skip to content

Commit 902756b

Browse files
author
Rosie Ellis
committed
Limit this to services/workers
1 parent 5fc18fc commit 902756b

2 files changed

Lines changed: 10 additions & 6 deletions

File tree

SingularityService/src/main/java/com/hubspot/singularity/config/SingularityConfiguration.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -453,7 +453,7 @@ public class SingularityConfiguration extends Configuration {
453453

454454
private boolean skipPersistingTooLongTaskIds = false;
455455

456-
private boolean allowSettingRequestInstances = false;
456+
private boolean allowEmptyRequestInstances = false;
457457

458458
public long getAskDriverToKillTasksAgainAfterMillis() {
459459
return askDriverToKillTasksAgainAfterMillis;
@@ -2122,11 +2122,11 @@ public void setSkipPersistingTooLongTaskIds(boolean skipPersistingTooLongTaskIds
21222122
this.skipPersistingTooLongTaskIds = skipPersistingTooLongTaskIds;
21232123
}
21242124

2125-
public boolean allowSettingRequestInstances() {
2126-
return allowSettingRequestInstances;
2125+
public boolean allowEmptyRequestInstances() {
2126+
return allowEmptyRequestInstances;
21272127
}
21282128

2129-
public void setAllowSettingRequestInstances(boolean allowSettingRequestInstances) {
2130-
this.allowSettingRequestInstances = allowSettingRequestInstances;
2129+
public void setallowEmptyRequestInstances(boolean allowEmptyRequestInstances) {
2130+
this.allowEmptyRequestInstances = allowEmptyRequestInstances;
21312131
}
21322132
}

SingularityService/src/main/java/com/hubspot/singularity/data/SingularityValidator.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -231,7 +231,7 @@ public SingularityRequest checkSingularityRequest(
231231
request.getId()
232232
);
233233

234-
if (singularityConfiguration.allowSettingRequestInstances()) {
234+
if (singularityConfiguration.allowEmptyRequestInstances()) {
235235
checkBadRequest(
236236
(
237237
!existingRequest.flatMap(SingularityRequest::getInstances).isPresent() &&
@@ -242,6 +242,10 @@ public SingularityRequest checkSingularityRequest(
242242
);
243243

244244
if (
245+
(
246+
request.getRequestType().equals(RequestType.SERVICE) ||
247+
request.getRequestType().equals(RequestType.WORKER)
248+
) &&
245249
existingRequest.flatMap(SingularityRequest::getInstances).isPresent() &&
246250
!request.getInstances().isPresent()
247251
) {

0 commit comments

Comments
 (0)