fix: allow attaching job name to processors

Signed-off-by: Brent Hoover <[email protected]>
NicholasWilsonDEV · May 19, 2023 · ee4d9e7 · ee4d9e7
1 parent b1c0d89
commit ee4d9e7
Showing 1 changed file with 13 additions and 1 deletion.
diff --git a/packages/api-plugin-bull-queue/src/api/createQueue.js b/packages/api-plugin-bull-queue/src/api/createQueue.js
@@ -47,11 +47,23 @@ export default function createQueue(context, queueName, options = defaultOptions
   const newQueue = new Queue(queueName, options.url ?? REDIS_SERVER, options);
   context.bullQueue.jobQueues[queueName] = newQueue;
   if (REACTION_WORKERS_ENABLED) { // If workers are not enabled, allow adding jobs to queue but don't process them
-    newQueue.process((job) => processorFn(job.data, job));
+    if (options.jobName) {
+      newQueue.process(options.jobName, (job) => processorFn(job.data, job));
+    } else {
+      newQueue.process((job) => processorFn(job.data, job));
+    }
   }
 
   newQueue.on("error", (error) => {
     Logger.error({ error, queueName, ...logCtx }, "Error processing background job");
   });
+
+  newQueue.on("stalled", (job) => {
+    Logger.error({ queueName, options, job, ...logCtx }, "Job stalled");
+  });
+
+  newQueue.on("failed", (job, err) => {
+    Logger.error({ ...err, ...logCtx }, "Job process failed");
+  });
   return newQueue;
 }