Variable status check concurrency

eco-stake · May 24, 2024 · f705845 · f705845
1 parent 01b259b
commit f705845
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/status/healthMonitor.js b/status/healthMonitor.js
@@ -8,10 +8,11 @@ const ALLOWED_ERRORS = 10
 const ERROR_COOLDOWN = 10 * 60
 const RATE_LIMIT_COOLDOWN = 3 * 24 * 60 * 60
 const HEALTH_TIMEOUT = 5000
+const HEALTH_CONCURRENCY = parseInt(process.env.HEALTH_CONCURRENCY || 20)
 
 function HealthMonitor() {
   const agent = createAgent();
-  const queue = new PQueue({ concurrency: 20 });
+  const queue = new PQueue({ concurrency: HEALTH_CONCURRENCY });
 
   async function refreshApis(client, chains) {
     timeStamp('Running health checks');