diff --git a/services/track-changes/app/coffee/HistoryManager.coffee b/services/track-changes/app/coffee/HistoryManager.coffee
index 67fb7c789f..41feff05c3 100644
--- a/services/track-changes/app/coffee/HistoryManager.coffee
+++ b/services/track-changes/app/coffee/HistoryManager.coffee
@@ -39,7 +39,7 @@ module.exports = HistoryManager =
 			HistoryManager.compressAndSaveRawUpdates doc_id, rawUpdates, (error) ->
 				return callback(error) if error?
 				logger.log doc_id: doc_id, "compressed and saved doc updates"
-				RedisManager.deleteOldestRawUpdates doc_id, HistoryManager.REDIS_READ_BATCH_SIZE, (error) ->
+				RedisManager.deleteOldestRawUpdates doc_id, length, (error) ->
 					return callback(error) if error?
 					if length == HistoryManager.REDIS_READ_BATCH_SIZE
 						# There might be more updates
diff --git a/services/track-changes/test/unit/coffee/HistoryManager/HistoryManagerTests.coffee b/services/track-changes/test/unit/coffee/HistoryManager/HistoryManagerTests.coffee
index 7b20efeb63..88efcfe606 100644
--- a/services/track-changes/test/unit/coffee/HistoryManager/HistoryManagerTests.coffee
+++ b/services/track-changes/test/unit/coffee/HistoryManager/HistoryManagerTests.coffee
@@ -132,7 +132,7 @@ describe "HistoryManager", ->
 
 			it "should delete the batch of uncompressed updates that was just processed", ->
 				@RedisManager.deleteOldestRawUpdates
-					.calledWith(@doc_id, @HistoryManager.REDIS_READ_BATCH_SIZE)
+					.calledWith(@doc_id, @updates.length)
 					.should.equal true
 
 			it "should call the callback", ->