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 ( load = await mapper[strippedIdentifier].schedule( { expiration: 600000 }, async () => { - return await Promise.race([ - new Promise(async (res) => { - await timer(300000); - res(true as T); - }), - new Promise(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,