fix:reduced concurrency

dappforce · Feb 20, 2024 · c212d4c · c212d4c
1 parent 2de7778
commit c212d4c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/modules/queueProcessor/services/consumers/accountAggregationFlow.consumer.ts b/src/modules/queueProcessor/services/consumers/accountAggregationFlow.consumer.ts
@@ -19,7 +19,7 @@ export class AccountAggregationFlowConsumer {
 
   @Process({
     name: SubIdAggregatorJobName.REFRESH_TX_HISTORY_FOR_ACCOUNT_ON_DEMAND,
-    concurrency: 300,
+    concurrency: 100,
   })
   async refreshTxHistory(job: Job<RefreshAccountTxHistoryJobDataDto>) {
     await job.takeLock();
@@ -53,7 +53,7 @@ export class AccountAggregationFlowConsumer {
 
   @Process({
     name: SubIdAggregatorJobName.REFRESH_TX_HISTORY_FOR_ACCOUNT_SCHEDULED,
-    concurrency: 300,
+    concurrency: 100,
   })
   async refreshTxHistoryScheduled(job: Job<RefreshAccountTxHistoryJobDataDto>) {
     await job.takeLock();