var kue = require('kue')
  , eslint = require('./workers/eslint')
  , jobs = kue.createQueue({
      redis: {
        port: process.env.REDIS_PORT || 6379,
        host: process.env.REDIS_HOST || '127.0.0.1',
        auth: process.env.REDIS_PASSWORD || null
      }
    });

// TODO: Job may need to retry?
jobs.process('eslint', function(job, done) {
  eslint.process(job, done);
});

module.exports = jobs;
@@ -26,44 +26,21 @@
   , 
-eslint = require('./workers/eslint')
+Job = kue.Job
 %0A  ,
@@ -242,17 +242,57 @@
 %7D%0A    %7D)
-;
+%0A  , eslint = require('./workers/eslint')
 %0A%0A// TOD
@@ -362,16 +362,16 @@
 done) %7B%0A
-
   eslint
@@ -396,16 +396,271 @@
 );%0A%7D);%0A%0A
+// Removes completed jobs%0Ajobs.on('job complete', function(id) %7B%0A  Job.get(id, function(err, job) %7B%0A    if (err) return;%0A%0A    job.remove(function (err) %7B%0A      if (err) throw err;%0A      console.log('Removed completed job #%25d', job.id);%0A    %7D);%0A  %7D);%0A%7D);%0A%0A
 module.e

Remove completed jobs