Fix bug in termination condition

This commit is contained in:
Daniel Gasienica 2018-04-03 12:30:13 -04:00
parent 9c7afab21b
commit ed77378293

View file

@ -70,7 +70,7 @@ exports.processNext = async ({
const totalDuration = Date.now() - startTime; const totalDuration = Date.now() - startTime;
const numProcessed = messagesRequiringSchemaUpgrade.length; const numProcessed = messagesRequiringSchemaUpgrade.length;
const done = numProcessed > 0; const done = numProcessed < count;
return { return {
done, done,
numProcessed, numProcessed,