diff --git a/src/backend/index.ts b/src/backend/index.ts index b8b48fa6..37a4dae7 100644 --- a/src/backend/index.ts +++ b/src/backend/index.ts @@ -18,7 +18,7 @@ import { parseVersion } from "./version.js"; import { initServer } from "./server/index.js"; import { createHeartbeatClientsTask } from "./tasks/heartbeatClients.js"; import { createHeartbeatSourcesTask } from "./tasks/heartbeatSources.js"; -import { isDebugMode, parseBool, retry, sleep } from "./utils.js"; +import { isDebugMode, parseBool, retry } from "./utils.js"; import { readJson } from './utils/DataUtils.js'; //import { createVegaGenerator } from './utils/SchemaUtils.js'; import ScrobbleClients from './scrobblers/ScrobbleClients.js'; diff --git a/src/backend/utils/AsyncUtils.ts b/src/backend/utils/AsyncUtils.ts index 949ad901..02bc77ad 100644 --- a/src/backend/utils/AsyncUtils.ts +++ b/src/backend/utils/AsyncUtils.ts @@ -62,7 +62,7 @@ export function staggerMapper(options: StaggerOptions) { return (mapper: Mapper) => async (x: Element, index: number) => { if (index < concurrency) { - sleep(initialStagger); + await sleep(initialStagger); initialStagger += initialInterval; } else { const s = Math.min((Math.random() * 1000), maxRandomStagger)