From 506bb14d2223e8f58df5063e449cb131b9d7462e Mon Sep 17 00:00:00 2001 From: Peter Steinberger Date: Wed, 15 Jul 2026 10:49:43 -0700 Subject: [PATCH] test: tighten more async polling (#108385) --- test/mcp-show-redact.e2e.test.ts | 2 +- test/scripts/check-deadcode-unused-files.test.ts | 4 ++-- test/scripts/check-extension-package-tsc-boundary.test.ts | 4 ++-- test/scripts/run-oxlint.test.ts | 4 ++-- test/scripts/telegram-user-crabbox-proof.test.ts | 2 +- test/scripts/tsdown-build.test.ts | 4 ++-- ui/src/e2e/chat-flow.e2e.test.ts | 2 +- ui/src/e2e/cron-filters.e2e.test.ts | 2 +- ui/src/e2e/session-management.e2e.test.ts | 2 +- ui/src/pages/plugins/plugins.e2e.test.ts | 2 +- .../pages/workboard/workboard-status-persistence.e2e.test.ts | 2 +- ui/src/pages/workboard/workboard.e2e.test.ts | 2 +- 12 files changed, 16 insertions(+), 16 deletions(-) diff --git a/test/mcp-show-redact.e2e.test.ts b/test/mcp-show-redact.e2e.test.ts index 4fecd13bfd1..fbe5445dbc9 100644 --- a/test/mcp-show-redact.e2e.test.ts +++ b/test/mcp-show-redact.e2e.test.ts @@ -58,7 +58,7 @@ async function waitForChatFinal( return payload; } } - await new Promise((resolve) => setTimeout(resolve, 50)); + await new Promise((resolve) => setTimeout(resolve, 10)); } throw new Error( `timed out waiting for chat final runId=${runId}; events=${JSON.stringify( diff --git a/test/scripts/check-deadcode-unused-files.test.ts b/test/scripts/check-deadcode-unused-files.test.ts index 2af2e5cfca4..92b06e812e6 100644 --- a/test/scripts/check-deadcode-unused-files.test.ts +++ b/test/scripts/check-deadcode-unused-files.test.ts @@ -50,7 +50,7 @@ async function waitForFile(filePath: string, timeoutMs: number): Promise { if (existsSync(filePath)) { return; } - await sleep(25); + await sleep(5); } throw new Error(`timeout waiting for ${filePath}`); } @@ -61,7 +61,7 @@ async function waitForDead(pid: number, timeoutMs: number): Promise { if (!isProcessAlive(pid)) { return; } - await sleep(25); + await sleep(5); } throw new Error(`process still alive: ${pid}`); } diff --git a/test/scripts/check-extension-package-tsc-boundary.test.ts b/test/scripts/check-extension-package-tsc-boundary.test.ts index 8156b31fa49..e962260be71 100644 --- a/test/scripts/check-extension-package-tsc-boundary.test.ts +++ b/test/scripts/check-extension-package-tsc-boundary.test.ts @@ -69,7 +69,7 @@ async function waitForFile(filePath: string, timeoutMs: number): Promise { if (fs.existsSync(filePath)) { return; } - await sleep(25); + await sleep(5); } throw new Error(`timeout waiting for ${filePath}`); } @@ -80,7 +80,7 @@ async function waitForDead(pid: number, timeoutMs: number): Promise { if (!isProcessAlive(pid)) { return; } - await sleep(25); + await sleep(5); } throw new Error(`process still alive: ${pid}`); } diff --git a/test/scripts/run-oxlint.test.ts b/test/scripts/run-oxlint.test.ts index 4fedd2adb1f..171b7d01a25 100644 --- a/test/scripts/run-oxlint.test.ts +++ b/test/scripts/run-oxlint.test.ts @@ -510,9 +510,9 @@ describe("run-oxlint", () => { " try { process.kill(pid, 0); return true; } catch { return false; }", "};", "const waitFor = async (predicate) => {", - " for (let attempt = 0; attempt < 100; attempt += 1) {", + " for (let attempt = 0; attempt < 500; attempt += 1) {", " if (predicate()) return true;", - " await sleep(25);", + " await sleep(5);", " }", " return false;", "};", diff --git a/test/scripts/telegram-user-crabbox-proof.test.ts b/test/scripts/telegram-user-crabbox-proof.test.ts index 951e9c6c850..2c8f832efe8 100644 --- a/test/scripts/telegram-user-crabbox-proof.test.ts +++ b/test/scripts/telegram-user-crabbox-proof.test.ts @@ -75,7 +75,7 @@ async function waitFor(predicate: () => boolean, timeoutMs = 5_000): Promise { if (fs.existsSync(filePath)) { return; } - await sleep(25); + await sleep(5); } throw new Error(`timed out waiting for ${filePath}`); } @@ -77,7 +77,7 @@ async function waitForDead(pid: number, timeoutMs: number): Promise { if (!isProcessAlive(pid)) { return; } - await sleep(25); + await sleep(5); } throw new Error(`timed out waiting for pid ${pid} to exit`); } diff --git a/ui/src/e2e/chat-flow.e2e.test.ts b/ui/src/e2e/chat-flow.e2e.test.ts index 60777a04459..d3d31bf40ec 100644 --- a/ui/src/e2e/chat-flow.e2e.test.ts +++ b/ui/src/e2e/chat-flow.e2e.test.ts @@ -47,7 +47,7 @@ async function waitForRequests( return requests; } await new Promise((resolve) => { - setTimeout(resolve, 50); + setTimeout(resolve, 10); }); } throw new Error(`Timed out waiting for ${count} ${method} requests`); diff --git a/ui/src/e2e/cron-filters.e2e.test.ts b/ui/src/e2e/cron-filters.e2e.test.ts index a1be8cd5b58..d031991fa49 100644 --- a/ui/src/e2e/cron-filters.e2e.test.ts +++ b/ui/src/e2e/cron-filters.e2e.test.ts @@ -69,7 +69,7 @@ async function waitForCronListRequest( return match; } await new Promise((resolve) => { - setTimeout(resolve, 50); + setTimeout(resolve, 10); }); } throw new Error(`No matching cron.list request found: ${JSON.stringify(requests)}`); diff --git a/ui/src/e2e/session-management.e2e.test.ts b/ui/src/e2e/session-management.e2e.test.ts index 94fcf9cc704..f70681c1a9b 100644 --- a/ui/src/e2e/session-management.e2e.test.ts +++ b/ui/src/e2e/session-management.e2e.test.ts @@ -108,7 +108,7 @@ async function waitForPatch( return match; } await new Promise((resolve) => { - setTimeout(resolve, 50); + setTimeout(resolve, 10); }); } throw new Error(`No matching sessions.patch request found: ${JSON.stringify(requests)}`); diff --git a/ui/src/pages/plugins/plugins.e2e.test.ts b/ui/src/pages/plugins/plugins.e2e.test.ts index 4232a0caf58..72b05ca8f89 100644 --- a/ui/src/pages/plugins/plugins.e2e.test.ts +++ b/ui/src/pages/plugins/plugins.e2e.test.ts @@ -206,7 +206,7 @@ async function waitForNextRequest( } } await new Promise((resolve) => { - setTimeout(resolve, 50); + setTimeout(resolve, 10); }); } throw new Error(`Timed out waiting for the next ${method} request`); diff --git a/ui/src/pages/workboard/workboard-status-persistence.e2e.test.ts b/ui/src/pages/workboard/workboard-status-persistence.e2e.test.ts index f3c1292f532..b6683919c86 100644 --- a/ui/src/pages/workboard/workboard-status-persistence.e2e.test.ts +++ b/ui/src/pages/workboard/workboard-status-persistence.e2e.test.ts @@ -197,7 +197,7 @@ async function waitForRequestCount( stableSince = null; } await new Promise((resolve) => { - setTimeout(resolve, 50); + setTimeout(resolve, 10); }); } throw new Error( diff --git a/ui/src/pages/workboard/workboard.e2e.test.ts b/ui/src/pages/workboard/workboard.e2e.test.ts index eec796ce24c..f92fc2521bb 100644 --- a/ui/src/pages/workboard/workboard.e2e.test.ts +++ b/ui/src/pages/workboard/workboard.e2e.test.ts @@ -117,7 +117,7 @@ async function waitForRequests( return requests; } await new Promise((resolve) => { - setTimeout(resolve, 50); + setTimeout(resolve, 10); }); } throw new Error(`Timed out waiting for ${count} ${method} requests`);