Em
bull
Não é possível repetir o mesmo trabalho imediatamente após sua falha antes de pegar o próximo trabalho na fila. Solução:
- Crie um novo trabalho e defina sua prioridade para um valor menor que o tipo de trabalho atual.
- Libere a tarefa com falha (
resolve()
oudone()
) - Este novo trabalho será escolhido imediatamente pelo
bull
para processamento.
Código de exemplo:no código abaixo Job-3 falhará e criará um novo trabalho e assim por diante até que o "propósito do trabalho" seja bem-sucedido em algum ponto do tempo.
var Queue = require('bull');
let redisOptions = {
redis: { port: 6379, host: '127.0.0.1' }
}
var myQueue = new Queue('Linear-Queue', redisOptions);
myQueue.process('Type-1', function (job, done) {
console.log(`Processing Job-${job.id} Attempt: ${job.attemptsMade}`);
downloadFile(job, async function (error) {
if (error) {
await repeatSameJob(job, done);
} else {
done();
}
});
});
async function repeatSameJob(job, done) {
let newJob = await myQueue.add('Type-1', job.data, { ...{ priority: 1 }, ...job.opts });
console.log(`Job-${job.id} failed. Creating new Job-${newJob.id} with highest priority for same data.`);
done(true);
}
function downloadFile(job, done) {
setTimeout(async () => {
done(job.data.error)
}, job.data.time);
}
myQueue.on('completed', function (job, result) {
console.log("Completed: Job-" + job.id);
});
myQueue.on('failed', async function (job, error) {
console.log("Failed: Job-" + job.id);
});
let options = {
removeOnComplete: true, // removes job from queue on success
removeOnFail: true // removes job from queue on failure
}
for (let i = 1; i <= 5; i++) {
let error = false;
if (i == 3) { error = true; }
setTimeout(i => {
let jobData = {
time: i * 2000,
error: error,
description: `Job-${i}`
}
myQueue.add('Type-1', jobData, options);
}, i * 2000, i);
}
Saída: