my solution for stuck jobs in active and inactive state, but is it possible to make this run in every job process? without restart the server
Author: hotaryuzakiCreated Apr 24, 2020Updated Apr 24, 2020
i don't know this is a good or a bad way, because i'm new in Kue. i got to maintenance my company system, they used Kue when develop this. and sadly this repo no longer maintained.
here is my solution, it works good for me. but i cannot make this works as programatically when server is running. (we have to restart the server to clear all mess)
so my question is it possible to make this run in every job process? maybe run as a function and we can call it when needed??
/***
REMOVE ALL STUCK JOBS WHEN SAILS LIFT
THEN RUN QUEUE PROCESS
***/
try {
// GET SPECIFIC JOB BY JOB TYPE - CURRENTLY JUST FOR CHECKING STATUS
kue.Job.rangeByType(jobType1, 'inactive', 0, 100, 'asc', function(err, jobs) {
var ids = [];
jobs.forEach(function(job) {
ids.push(job.id);
});
console.log(jobType1, '=> STUCK JOBS INACTIVE TOTAL:', jobs.length, '=', ids);
});
kue.Job.rangeByType(jobType2, 'inactive', 0, 100, 'asc', function(err, jobs) {
var ids = [];
jobs.forEach(function(job) {
ids.push(job.id);
});
console.log(jobType2, '=> STUCK JOBS INACTIVE TOTAL:', jobs.length, '=', ids);
});
kue.Job.rangeByType(jobType3, 'inactive', 0, 100, 'asc', function(err, jobs) {
var ids = [];
jobs.forEach(function(job) {
ids.push(job.id);
});
console.log(jobType3, '=> STUCK JOBS INACTIVE TOTAL:', jobs.length, '=', ids);
});
/*########## KUE GET ALL ACTIVE JOBS ##########*/
queue.active(function(err, ids) {
console.log('QUEUE => JOBS ACTIVE STUCK IDS:', ids)
ids.forEach(function(id) {
kue.Job.get(id, function(err, job) {
job.inactive(); // SET ALL STUCK JOBS ACTIVE TO INACTIVE
});
});
/*########## KUE GET ALL INACTIVE JOBS ##########*/
queue.inactive(function(err, ids) {
console.log('QUEUE => JOBS INACTIVE STUCK IDS:', ids)
ids.forEach(function(id) {
kue.Job.get(id, function(err, job) {
// REMOVE ALL STUCK JOBS
job.remove(function(err){
if (err) throw err;
console.log('QUEUE =>', job.type, '=> JOB REMOVED #', job.id);
});
});
});
queue.process(jobType1, function(job, done){
try {
// process
done();
} catch(e) {
done(e);
}
});
queue.process(jobType2, function(job, done){
try {
// process
done();
} catch(e) {
done(e);
}
});
queue.process(jobType3, function(job, done){
try {
// process
done();
} catch(e) {
done(e);
}
});
});
});
} catch(e) {
// statements
console.log(e);
}```Source: Automattic/kue