From d2146a8ac7616584ecab16a39e35d1c1ffee7734 Mon Sep 17 00:00:00 2001
From: Nevo David <me@nevos.io>
Date: Fri, 8 Aug 2025 04:05:36 +0700
Subject: [PATCH] feat: less concurrency

---
 .../helpers/src/utils/concurrency.service.ts     | 16 +++-------------
 .../src/bull-mq-transport-new/strategy.ts        |  2 +-
 2 files changed, 4 insertions(+), 14 deletions(-)

diff --git a/libraries/helpers/src/utils/concurrency.service.ts b/libraries/helpers/src/utils/concurrency.service.ts
index bd35f469..7d447e87 100644
--- a/libraries/helpers/src/utils/concurrency.service.ts
+++ b/libraries/helpers/src/utils/concurrency.service.ts
@@ -26,19 +26,9 @@ export const concurrency = async <T>(
     load = await mapper[strippedIdentifier].schedule<T>(
       { expiration: 600000 },
       async () => {
-        return await Promise.race<T>([
-          new Promise<T>(async (res) => {
-            await timer(300000);
-            res(true as T);
-          }),
-          new Promise<T>(async (res) => {
-            try {
-              return res(await func());
-            } catch (err) {
-              res(err as T);
-            }
-          }),
-        ]);
+        try {
+          return await func();
+        } catch (err) {}
       }
     );
   } catch (err) {}
diff --git a/libraries/nestjs-libraries/src/bull-mq-transport-new/strategy.ts b/libraries/nestjs-libraries/src/bull-mq-transport-new/strategy.ts
index 71216428..8cb52190 100644
--- a/libraries/nestjs-libraries/src/bull-mq-transport-new/strategy.ts
+++ b/libraries/nestjs-libraries/src/bull-mq-transport-new/strategy.ts
@@ -34,7 +34,7 @@ export class BullMqServer extends Server implements CustomTransportStrategy {
           },
           {
             maxStalledCount: 10,
-            concurrency: 10,
+            concurrency: 5,
             connection: ioRedis,
             removeOnComplete: {
               count: 0,