start capturing max concurrent workers in env to the service

rudderlabs · Feb 26, 2024 · d9e606d · d9e606d
1 parent 9fa5374
commit d9e606d
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/util/openfaas/index.js b/src/util/openfaas/index.js
@@ -11,6 +11,7 @@ const stats = require('../stats');
 const { getMetadata, getTransformationMetadata } = require('../../v0/util');
 const { HTTP_STATUS_CODES } = require('../../v0/util/constant');
 
+const FAAS_MAX_CONCURRENT_WORKERS = process.env.FAAS_MAX_CONCURRENT_WORKERS || '1';
 const FAAS_BASE_IMG = process.env.FAAS_BASE_IMG || 'rudderlabs/openfaas-flask:main';
 const FAAS_MAX_PODS_IN_TEXT = process.env.FAAS_MAX_PODS_IN_TEXT || '40';
 const FAAS_MIN_PODS_IN_TEXT = process.env.FAAS_MIN_PODS_IN_TEXT || '1';
@@ -135,7 +136,10 @@ const deployFaasFunction = async (
       envProcess = `${envProcess} --code "${code}" --config-backend-url ${CONFIG_BACKEND_URL} --lvids "${lvidsString}"`;
     }
 
-    const envVars = {};
+    const envVars = {
+      max_concurrent_workers: FAAS_MAX_CONCURRENT_WORKERS,
+    };
+
     if (FAAS_ENABLE_WATCHDOG_ENV_VARS.trim().toLowerCase() === 'true') {
       envVars.max_inflight = FAAS_MAX_INFLIGHT;
       envVars.exec_timeout = FAAS_EXEC_TIMEOUT;