diff --git a/src/backend/utils/AsyncUtils.ts b/src/backend/utils/AsyncUtils.ts index 2455d037..9073b87a 100644 --- a/src/backend/utils/AsyncUtils.ts +++ b/src/backend/utils/AsyncUtils.ts @@ -47,7 +47,12 @@ export async function findIndexAsync( return index; } -export function staggerMapper(options: { maxRandomStagger?: number, initialInterval?: number, concurrency: number }) { +export interface StaggerOptions { + maxRandomStagger?: number, + initialInterval?: number, + concurrency: number + } +export function staggerMapper(options: StaggerOptions) { const { initialInterval = 300, maxRandomStagger = 300, @@ -60,7 +65,7 @@ export function staggerMapper(options: { maxRandomStagger?: sleep(initialStagger); initialStagger += initialInterval; } else { - const s = Math.max((Math.random() * 1000), maxRandomStagger) + const s = Math.min((Math.random() * 1000), maxRandomStagger) await sleep(s); } return await mapper(x, index);