diff --git a/src/modules/aggregatorStateManager/oneTimeJobsManager.service.ts b/src/modules/aggregatorStateManager/oneTimeJobsManager.service.ts
index 9bdbd62..6ce7219 100644
--- 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
index 6256664..2f3b6cf 100644
--- 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
index 89a400d..2bf71ff 100644
--- 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
index f433a4f..bbf3307 100644
--- 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);
+      }
     }
   }