jprdonnelly/qmi-cloud
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

queues logs

Browse Source
This commit is contained in:
Manuel Romero
2021-02-09 13:56:20 +01:00
parent 9dd091f982
commit 0801f84b10
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
qmi-cloud-common/queues.js
View File

@@ -22,7 +22,7 @@ export const queues = {
for (let key in queues) {
queues[key].on('completed', function(job, result) {
//console.log(`Queues# Job ${job.id} completed! Result`, result);
console.log(`Queues# Job ${job.id} completed!`);
console.log(`Queue ${key}# Job ${job.id} completed!`);
});
@@ -31,13 +31,13 @@ for (let key in queues) {
});
queues[key].on('waiting', function(jobId){
console.log(`Queues# Job ${jobId} is waiting...`);
console.log(`Queue ${key}# Job ${jobId} is waiting...`);
// A Job is waiting to be processed as soon as a worker is idling.
});
queues[key].on('active', function(job, jobPromise){
// A job has started. You can use `jobPromise.cancel()`` to abort it.
console.log(`Queues# Job ${job.id} is now active`);
console.log(`Queue ${key}# Job ${job.id} is now active`);
});
queues[key].on('stalled', function(job){
@@ -47,12 +47,12 @@ for (let key in queues) {
queues[key].on('progress', function(job, progress){
// A job's progress was updated!
console.log(`Queues# Job ${job.id} is ${progress * 100}% ready!`);
console.log(`Queue ${key}# Job ${job.id} is ${progress * 100}% ready!`);
});
queues[key].on('failed', function(job, err){
// A job failed with reason `err`!
console.log(`Queues# Job ${job.id} has failed:`, err);
console.log(`Queue ${key}# Job ${job.id} has failed:`, err);
});
}