LLM/moltbot
1
0
Fork 0
mirror of https://github.com/moltbot/moltbot.git synced 2026-05-13 15:47:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: wait for qa suite stagger starts

Browse Source
This commit is contained in:
Peter Steinberger
2026-05-11 17:12:42 +01:00
parent d104793520
commit 902e4807c4
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
extensions/qa-lab/src/suite-planning.test.ts
View File

@@ -1,7 +1,7 @@
import { lstat, mkdir, mkdtemp, rm, symlink } from "node:fs/promises";
import os from "node:os";
import path from "node:path";
import { describe, expect, it } from "vitest";
import { describe, expect, it, vi } from "vitest";
import { defaultQaSuiteConcurrencyForTransport } from "./qa-transport-registry.js";
import {
collectQaSuiteGatewayConfigPatch,
@@ -122,7 +122,11 @@ describe("qa suite planning helpers", () => {
const sleeps: number[] = [];
const releaseSleeps: Array<() => void> = [];
const started: number[] = [];
const tick = () => new Promise((resolve) => setTimeout(resolve, 0));
const waitForStarted = async (expected: number[]) => {
await vi.waitFor(() => {
expect(started).toEqual(expected);
});
};
const resultPromise = mapQaSuiteWithConcurrency(
[1, 2, 3, 4],
3,
@@ -141,17 +145,13 @@ describe("qa suite planning helpers", () => {
},
);
await tick();
expect(started).toEqual([1]);
await waitForStarted([1]);
releaseSleeps.shift()?.();
await tick();
expect(started).toEqual([1, 2]);
await waitForStarted([1, 2]);
releaseSleeps.shift()?.();
await tick();
expect(started).toEqual([1, 2, 3]);
await waitForStarted([1, 2, 3]);
releaseSleeps.shift()?.();
await tick();
expect(started).toEqual([1, 2, 3, 4]);
await waitForStarted([1, 2, 3, 4]);
const result = await resultPromise;
expect(result).toEqual([1, 2, 3, 4]);