From f58d4d1191996ddd3aa388bb7d2ed12a8675ab1e Mon Sep 17 00:00:00 2001
From: Vytor Calixto <vytorcalixto@gmail.com>
Date: Mon, 10 Jul 2017 09:21:38 -0300
Subject: [PATCH] Add done() callback to agenda job
---
src/libs/agenda.js | 6 +++++-
src/libs/jobs/download.js | 1 +
2 files changed, 6 insertions(+), 1 deletion(-)
diff --git a/src/libs/agenda.js b/src/libs/agenda.js
index 1c0ce568..6d7ef1d4 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 720dce7a..f9cf400e 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');
--
GitLab