public MongoCommit execute() throws Exception {
DBCollection commitCollection = nodeStore.getCommitCollection();
DBObject query = QueryBuilder.start(MongoCommit.KEY_FAILED).notEquals(Boolean.TRUE)
.and(MongoCommit.KEY_REVISION_ID).is(revisionId)
.get();
<BUG>LOG.debug(String.format("Executing query: %s", query));
</BUG>
DBObject dbObject = commitCollection.findOne(query);
if (dbObject == null) {
throw new Exception(String.format("Commit with revision %d could not be found", revisionId));

public MongoCommit execute() throws Exception {
DBCollection commitCollection = nodeStore.getCommitCollection();
DBObject query = QueryBuilder.start(MongoCommit.KEY_FAILED).notEquals(Boolean.TRUE)
.and(MongoCommit.KEY_REVISION_ID).is(revisionId)
.get();
LOG.debug("Executing query: {}", query);
DBObject dbObject = commitCollection.findOne(query);
if (dbObject == null) {
throw new Exception(String.format("Commit with revision %d could not be found", revisionId));
