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
- Dominant language
- JavaScript
- Stars
- 9.4k
- Forks
- 858
- PR merge metrics
- No merged PRs in 30d
Description
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);
}```
Contributor guide
No contributing guide indexed for this repository
Research direction
Start by tracing the Kue APIs used here: kue.Job.rangeByType, queue.active, queue.inactive, kue.Job.get, job.inactive, job.remove, and queue.process. Determine whether the cleanup can be invoked while the server is running and made available to every job process without a restart; done would require a defined, reliable runtime behavior rather than the current startup-only workaround.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- javascript, node.js, redis
- Domain
- backend
- Issue type
- Feature
- Difficulty
- 5/5
- Estimated time
- Over a week
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 20/100