diff --git a/libraries/helpers/src/utils/concurrency.service.ts b/libraries/helpers/src/utils/concurrency.service.ts index 3881d492..3a3a80b8 100644 --- a/libraries/helpers/src/utils/concurrency.service.ts +++ b/libraries/helpers/src/utils/concurrency.service.ts @@ -1,5 +1,6 @@ import { ioRedis } from '@gitroom/nestjs-libraries/redis/redis.service'; import Bottleneck from 'bottleneck'; +import { timer } from '@gitroom/helpers/utils/timer'; const connection = new Bottleneck.IORedisConnection({ client: ioRedis, @@ -20,7 +21,9 @@ export async function concurrencyService( load = await bottleneck .key(identifier.split('-')[0]) .schedule({ expiration: 120_000 }, async () => { - return await func(); + const res = await func(); + await timer(2000); + return res; }); } catch (err) {}