handle throttle failure

bcgov · Dec 6, 2024 · aa60f61 · aa60f61
1 parent 98b0687
commit aa60f61
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/src/app.module.ts b/src/app.module.ts
@@ -83,6 +83,7 @@ import { RssModule } from './rss/rss.module';
           prefix: 'nb',
           defaultJobOptions: {
             removeOnComplete: true,
+            removeOnFail: true,
           },
         };
         const connection = appConfigService.get('queue.connection');

diff --git a/src/common/common.service.ts b/src/common/common.service.ts
@@ -76,8 +76,7 @@ export class CommonService {
           prefix: queue.opts.prefix,
         });
         const queuedID = [];
-        // IMPORTANT: place queueEvents.on before myQueue.add
-        queueEvents.on('completed', async ({ jobId }) => {
+        const queueEventHandler = async ({ jobId }) => {
           if (!j?.id) {
             queuedID.push(jobId);
             return;
@@ -95,7 +94,11 @@ export class CommonService {
             reject(ex);
           }
           queueEvents.close();
-        });
+        };
+        // IMPORTANT: place queueEvents.on before myQueue.add
+        queueEvents.on('completed', queueEventHandler);
+        queueEvents.on('failed', queueEventHandler);
+
         await queueEvents.waitUntilReady();
         const j = await queue.add('', undefined, { priority: opts.priority });
         // extra guard in case queueEvents.on is called before j is assigned.