From a8d20734aa73b3e536b75a5f705601bea6f3836e Mon Sep 17 00:00:00 2001 From: FoxxMD Date: Tue, 24 Mar 2026 20:20:37 +0000 Subject: [PATCH] fix: Fix wrong operation for maxRandomStagger --- src/backend/utils/AsyncUtils.ts | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) 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); -- 2.51.2