fix: added errors handling

dappforce · Mar 13, 2024 · 8701508 · 8701508
1 parent cf251e3
commit 8701508
Show file tree

Hide file tree

Showing 4 changed files with 16 additions and 4 deletions.
diff --git a/src/modules/aggregatorStateManager/oneTimeJobsManager.service.ts b/src/modules/aggregatorStateManager/oneTimeJobsManager.service.ts
@@ -12,7 +12,7 @@ type OneTimeJob = { id: string; action: string } & {
 
 const oneTimeJobsList: OneTimeJob[] = [
   {
-    id: '1710336390624',
+    id: '1710336390625',
     action: 'removeAllActiveJobs',
     payload: {},
   },

diff --git a/src/modules/queueProcessor/services/producers/accountAggregationFlow.producer.ts b/src/modules/queueProcessor/services/producers/accountAggregationFlow.producer.ts
@@ -63,7 +63,11 @@ export class AccountAggregationFlowProducer {
     const allJobs = await this.accountAggregationFlowQueue.getJobs(['active']);
 
     for (const job of allJobs) {
-      await job.remove();
+      try {
+        await job.remove();
+      } catch (e) {
+        console.log(e);
+      }
     }
   }
 }
diff --git a/src/modules/queueProcessor/services/producers/datasourceChunksParallelHandling.producer.ts b/src/modules/queueProcessor/services/producers/datasourceChunksParallelHandling.producer.ts
@@ -65,7 +65,11 @@ export class DatasourceChunksParallelHandlingProducer {
     ]);
 
     for (const job of allJobs) {
-      await job.remove();
+      try {
+        await job.remove();
+      } catch (e) {
+        console.log(e);
+      }
     }
   }
 }
diff --git a/src/modules/queueProcessor/services/producers/datasourceHandling.producer.ts b/src/modules/queueProcessor/services/producers/datasourceHandling.producer.ts
@@ -74,7 +74,11 @@ export class DatasourceHandlingProducer {
     const allJobs = await this.datasourceHandlingQueue.getJobs(['active']);
 
     for (const job of allJobs) {
-      await job.remove();
+      try {
+        await job.remove();
+      } catch (e) {
+        console.log(e);
+      }
     }
   }