diff --git a/services/worker/src/index.js b/services/worker/src/index.js index 03cfb67..5c238d7 100644 --- a/services/worker/src/index.js +++ b/services/worker/src/index.js @@ -26,8 +26,9 @@ const createWorker = (queueName, handler) => { console.error(`[${queueName}] Job ${job.id} failed:`, err.message); }); - worker.on('progress', (job) => { - console.log(`[${queueName}] Job ${job.id} progress:`, job.progress()); + // job.progress is a property (the value set by updateProgress), not a function + worker.on('progress', (job, progress) => { + console.log(`[${queueName}] Job ${job.id} progress:`, progress); }); return worker;