diff --git a/libraries/helpers/src/utils/concurrency.service.ts b/libraries/helpers/src/utils/concurrency.service.ts index 99ee82fa..88417d95 100644 --- a/libraries/helpers/src/utils/concurrency.service.ts +++ b/libraries/helpers/src/utils/concurrency.service.ts @@ -23,15 +23,18 @@ export const concurrency = async ( }); let load: T; try { - load = await mapper[strippedIdentifier].schedule(async () => { - return await Promise.race([ - new Promise(async (res) => { - await timer(300000); - res(true as T); - }), - func(), - ]); - }); + load = await mapper[strippedIdentifier].schedule( + { expiration: 600000 }, + async () => { + return await Promise.race([ + new Promise(async (res) => { + await timer(300000); + res(true as T); + }), + func(), + ]); + } + ); } catch (err) {} return load;