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

Ensure test is isolated

Browse Source
This commit is contained in:
Daniel García Aubert 2016-10-28 12:24:23 +02:00
parent 97836e62b9
commit 1f657a4f94
2 changed files with 15 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
batch/job_backend.js
View File

@ -203,8 +203,8 @@ JobBackend.prototype.listWorkInProgressJob = function (callback) {
var usersName = Object.keys(users);
var usersQueue = queue(usersName.length);
usersName.forEach(function (userKey) {
usersQueue.defer(this.listWorkInProgressJobByUser.bind(this), userKey);
usersName.forEach(function (userName) {
usersQueue.defer(this.listWorkInProgressJobByUser.bind(this), userName);
}.bind(this));
usersQueue.awaitAll(function (err, results) {

19
test/integration/batch/job_backend.test.js
View File

@ -112,26 +112,33 @@ describe('job backend', function() {
});
it('.listWorkInProgressJobByUser() should retrieve WIP jobs of given user', function (done) {
jobBackend.listWorkInProgressJobByUser('vizzuality', function (err, jobs) {
var testStepsQueue = queue(1);
testStepsQueue.defer(redisUtils.clean, 'batch:wip:user:*');
testStepsQueue.defer(jobBackend.addWorkInProgressJob.bind(jobBackend), 'vizzuality', 'wadus');
testStepsQueue.defer(jobBackend.listWorkInProgressJobByUser.bind(jobBackend), 'vizzuality');
testStepsQueue.awaitAll(function (err, results) {
if (err) {
return done(err);
}
assert.ok(jobs.length);
assert.deepEqual(results[2], ['wadus']);
done();
});
});
it('.listWorkInProgressJob() should retrieve WIP users', function (done) {
var jobs = [{ user: 'userA', id: 'jobId1' }, { user: 'userA', id: 'jobId2' }, { user: 'userB', id: 'jobId3' }];
var testQueue = queue();
testQueue.defer(redisUtils.clean, 'batch:*');
var testStepsQueue = queue(1);
testStepsQueue.defer(redisUtils.clean, 'batch:wip:user:*');
jobs.forEach(function (job) {
testQueue.defer(jobBackend.addWorkInProgressJob.bind(jobBackend), job.user, job.id);
testStepsQueue.defer(jobBackend.addWorkInProgressJob.bind(jobBackend), job.user, job.id);
});
testQueue.awaitAll(function (err) {
testStepsQueue.awaitAll(function (err) {
if (err) {
done(err);
}