cartodb/CartoDB-SQL-API
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Use REDIS_DB as constant

Browse Source
This commit is contained in:
Daniel García Aubert 2016-05-17 19:48:55 +02:00
parent 672b8ef537
commit b06eaae5e6
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
batch/job_backend.js
View File

@ -2,6 +2,7 @@
var queue = require('queue-async'); var queue = require('queue-async');
var REDIS_PREFIX = 'batch:jobs:'; var REDIS_PREFIX = 'batch:jobs:';
var REDIS_DB = 5;
var JOBS_TTL_IN_SECONDS = global.settings.jobs_ttl_in_seconds || 48 * 3600; // 48 hours var JOBS_TTL_IN_SECONDS = global.settings.jobs_ttl_in_seconds || 48 * 3600; // 48 hours
var jobStatus = require('./job_status'); var jobStatus = require('./job_status');
var finalStatus = [ var finalStatus = [
@ -12,7 +13,6 @@ var finalStatus = [
]; ];
function JobBackend(metadataBackend, jobQueueProducer, jobPublisher, userIndexer) { function JobBackend(metadataBackend, jobQueueProducer, jobPublisher, userIndexer) {
this.db = 5;
this.metadataBackend = metadataBackend; this.metadataBackend = metadataBackend;
this.jobQueueProducer = jobQueueProducer; this.jobQueueProducer = jobQueueProducer;
this.jobPublisher = jobPublisher; this.jobPublisher = jobPublisher;
@ -79,7 +79,7 @@ JobBackend.prototype.get = function (job_id, callback) {
'failed_reason' 'failed_reason'
]; ];
self.metadataBackend.redisCmd(this.db, 'HMGET', redisParams , function (err, redisValues) { self.metadataBackend.redisCmd(REDIS_DB, 'HMGET', redisParams , function (err, redisValues) {
if (err) { if (err) {
return callback(err); return callback(err);
} }
@ -145,7 +145,7 @@ JobBackend.prototype.save = function (data, callback) {
var self = this; var self = this;
var redisParams = toRedisParams(data); var redisParams = toRedisParams(data);
self.metadataBackend.redisCmd(self.db, 'HMSET', redisParams , function (err) { self.metadataBackend.redisCmd(REDIS_DB, 'HMSET', redisParams , function (err) {
if (err) { if (err) {
return callback(err); return callback(err);
} }
@ -178,7 +178,7 @@ JobBackend.prototype.setTTL = function (data, callback) {
return callback(); return callback();
} }
self.metadataBackend.redisCmd(self.db, 'EXPIRE', [ redisKey, JOBS_TTL_IN_SECONDS ], callback); self.metadataBackend.redisCmd(REDIS_DB, 'EXPIRE', [ redisKey, JOBS_TTL_IN_SECONDS ], callback);
}; };
JobBackend.prototype.list = function (user, callback) { JobBackend.prototype.list = function (user, callback) {