feat: reduced stalledInterval value

dappforce · Nov 22, 2023 · 2bac075 · 2bac075
1 parent b417a43
commit 2bac075
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/deployment/feature-based/all.yaml b/deployment/feature-based/all.yaml
@@ -59,7 +59,7 @@ data:
   AGGREGATOR_REDIS_PREFIX: 'aggregator_queue_<BRANCH>'
   AGGREGATOR_REDIS_PORT: '6379'
   AGGREGATOR_REDIS_ENABLE_SSL: 'false'
-  AGGREGATOR_HISTORY_RENEW_INTERVAL_MS: '10000'
+  AGGREGATOR_HISTORY_RENEW_INTERVAL_MS: '60000'
   AGGREGATOR_GS_MAIN_CHUNK_BLOCKS_SIZE: '1000000'
   DATA_SOURCE_GSQUID_MAIN_POLKADOT: 'https://squid.subsquid.io/gs-main-polkadot/graphql'
   DATA_SOURCE_GSQUID_MAIN_KUSAMA: 'https://squid.subsquid.io/gs-main-kusama/graphql'

diff --git a/src/modules/queueProcessor/queueProcessor.module.ts b/src/modules/queueProcessor/queueProcessor.module.ts
@@ -49,7 +49,7 @@ import { DatasourceChunkParallelHandlingConsumer } from './services/consumers/da
         name: SubIdAggregatorQueueName.DATASOURCE_CHUNKS_PARALLEL_HANDLING,
         processors: [
           {
-            concurrency: 100,
+            concurrency: 101,
             name: 'TRANSFER_CHUNK',
             path: join(
               __dirname,

diff --git a/src/modulesConfig/bullModule.forRoot.ts b/src/modulesConfig/bullModule.forRoot.ts
@@ -70,7 +70,7 @@ export default {
       settings: {
         lockDuration: 20000, // Check for stalled jobs each 2 min
         lockRenewTime: 10000,
-        stalledInterval: 20 * 60 * 1000,
+        stalledInterval: 10 * 60 * 1000,
         maxStalledCount: 1,
       },
     };