diff --git a/lib/utils/process-jobs.js b/lib/utils/process-jobs.js index f6ee2c1..5544c22 100644 --- a/lib/utils/process-jobs.js +++ b/lib/utils/process-jobs.js @@ -117,6 +117,7 @@ module.exports = function(extraJob) { // Query to run against collection to see if we need to lock it const criteria = { _id: job.attrs._id, + name: job.attrs.name, lockedAt: null, nextRunAt: job.attrs.nextRunAt, disabled: {$ne: true}