Skip to content

Commit 278eab5

Browse files
committed
Remove extra verification step
1 parent 9295525 commit 278eab5

2 files changed

Lines changed: 0 additions & 16 deletions

File tree

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

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -458,7 +458,6 @@ public class SingularityConfiguration extends Configuration {
458458
private boolean skipPersistingTooLongTaskIds = false;
459459

460460
private boolean allowEmptyRequestInstances = false;
461-
private boolean verifyTaskDataWrites = false;
462461

463462
public long getAskDriverToKillTasksAgainAfterMillis() {
464463
return askDriverToKillTasksAgainAfterMillis;
@@ -2152,12 +2151,4 @@ public boolean allowEmptyRequestInstances() {
21522151
public void setAllowEmptyRequestInstances(boolean allowEmptyRequestInstances) {
21532152
this.allowEmptyRequestInstances = allowEmptyRequestInstances;
21542153
}
2155-
2156-
public boolean isVerifyTaskDataWrites() {
2157-
return verifyTaskDataWrites;
2158-
}
2159-
2160-
public void setVerifyTaskDataWrites(boolean verifyTaskDataWrites) {
2161-
this.verifyTaskDataWrites = verifyTaskDataWrites;
2162-
}
21632154
}

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

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1420,13 +1420,6 @@ private void createTaskAndDeletePendingTaskPrivate(SingularityTask task)
14201420
// Not checking isActive here, already called within offer check flow
14211421
leaderCache.putActiveTask(task.getTaskId());
14221422
taskCache.set(path, task);
1423-
if (configuration.isVerifyTaskDataWrites()) {
1424-
Optional<SingularityTask> maybeTask = getTaskCheckCache(task.getTaskId(), true);
1425-
if (!maybeTask.isPresent()) {
1426-
LOG.error("Found empty task after write for {}", task.getTaskId());
1427-
saveTaskDeletePendingInTransaction(hasErr, path, task, taskStatusHolder);
1428-
}
1429-
}
14301423
} catch (KeeperException.NodeExistsException nee) {
14311424
LOG.error("Task or active path already existed for {}", task.getTaskId());
14321425
} catch (Exception e) {

0 commit comments

Comments
 (0)