diff --git a/src/libs/agenda.js b/src/libs/agenda.js index 1c0ce568b9648c485aaf19fd8ca5a51c95a8dd23..6d7ef1d47ba5a260b5acc038bdbbda06cf8584f6 100644 --- a/src/libs/agenda.js +++ b/src/libs/agenda.js @@ -6,7 +6,11 @@ const Agenda = require('agenda'); const agenda = new Agenda({ db: { address: config.monq.uri, - collection: 'agendaJobs'} + collection: 'agendaJobs' + }, + maxConcurrency: 1, + defaultLockLimit: 0, + defaultLockLifetime: 86400*1000 }); require(`${libs}/jobs/download`)(agenda); diff --git a/src/libs/jobs/download.js b/src/libs/jobs/download.js index 720dce7a5f9889e2e9463a680460004942b678bd..f9cf400e487c6824626830a05e2b09460b43ebae 100644 --- a/src/libs/jobs/download.js +++ b/src/libs/jobs/download.js @@ -31,6 +31,7 @@ module.exports = function(agenda) { } console.log('MANDAR EMAIL'); console.log(body); + done(); }); }, (err) => { log.error('Error creating dump from DB');