From 8206b4ad025771c930dba2782551ccbacdb0511e Mon Sep 17 00:00:00 2001
From: Samuel Weirich <4281791+SamuelWei@users.noreply.github.com>
Date: Thu, 6 Feb 2025 16:56:56 +0000
Subject: [PATCH] Add concurrency

---
 docker-compose.yml | 2 ++
 src/worker/app.ts  | 3 ++-
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/docker-compose.yml b/docker-compose.yml
index c01db2c..5646460 100644
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@ -3,6 +3,8 @@ services:
     image: pilos/bbb-streaming-server:worker-dev-main
     depends_on:
       - redis
+    environment:
+      CONCURRENCY: 1
     deploy:
       mode: replicated
       replicas: 5
diff --git a/src/worker/app.ts b/src/worker/app.ts
index ffef452..f687e8a 100755
--- a/src/worker/app.ts
+++ b/src/worker/app.ts
@@ -4,6 +4,7 @@ import * as path from "node:path";
 import axios from 'axios';
 const redisHost: string = process.env.REDIS_HOST || 'redis';
 const redisPort: number = Number(process.env.REDIS_PORT) || 6379;
+const concurrency: number = Number(process.env.CONCURRENCY) || 1;
 
 // Create a Redis client
 const redis = new Redis({
@@ -17,7 +18,7 @@ const processorFile = path.join(__dirname, 'sandbox.js');
 const worker = new Worker('streams', processorFile,
   { connection: redis,
     removeOnComplete: { count: 0 },
-    concurrency: 50
+    concurrency: concurrency
   });
 
 worker.on("error", (error) => {