LLM/moltbot
1
0
Fork 0
mirror of https://github.com/moltbot/moltbot.git synced 2026-03-21 16:41:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: speed up supervisor test timing

Browse Source
This commit is contained in:
Peter Steinberger
2026-02-23 20:15:40 +00:00
parent 5a475259bb
commit 3b5a276a48
1 changed files with 21 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
src/process/supervisor/supervisor.test.ts
View File

@@ -4,6 +4,7 @@ import { createProcessSupervisor } from "./supervisor.js";
type ProcessSupervisor = ReturnType<typeof createProcessSupervisor>;
type SpawnOptions = Parameters<ProcessSupervisor["spawn"]>[0];
type ChildSpawnOptions = Omit<Extract<SpawnOptions, { mode: "child" }>, "backendId" | "mode">;
const OUTPUT_DELAY_MS = 40;
async function spawnChild(supervisor: ProcessSupervisor, options: ChildSpawnOptions) {
return supervisor.spawn({
@@ -19,8 +20,12 @@ describe("process supervisor", () => {
const run = await spawnChild(supervisor, {
sessionId: "s1",
// Delay stdout slightly so listeners are attached even on heavily loaded runners.
argv: [process.execPath, "-e", 'setTimeout(() => process.stdout.write("ok"), 200)'],
timeoutMs: 10_000,
argv: [
process.execPath,
"-e",
`setTimeout(() => process.stdout.write("ok"), ${OUTPUT_DELAY_MS})`,
],
timeoutMs: 2_000,
stdinMode: "pipe-closed",
});
const exit = await run.wait();
@@ -49,8 +54,8 @@ describe("process supervisor", () => {
const first = await spawnChild(supervisor, {
sessionId: "s1",
scopeKey: "scope:a",
argv: [process.execPath, "-e", "setTimeout(() => {}, 2_000)"],
timeoutMs: 10_000,
argv: [process.execPath, "-e", "setTimeout(() => {}, 1_000)"],
timeoutMs: 2_000,
stdinMode: "pipe-open",
});
@@ -59,8 +64,12 @@ describe("process supervisor", () => {
scopeKey: "scope:a",
replaceExistingScope: true,
// Small delay makes stdout capture deterministic by giving listeners time to attach.
argv: [process.execPath, "-e", 'setTimeout(() => process.stdout.write("new"), 200)'],
timeoutMs: 10_000,
argv: [
process.execPath,
"-e",
`setTimeout(() => process.stdout.write("new"), ${OUTPUT_DELAY_MS})`,
],
timeoutMs: 2_000,
stdinMode: "pipe-closed",
});
@@ -90,8 +99,12 @@ describe("process supervisor", () => {
const run = await spawnChild(supervisor, {
sessionId: "s-capture",
// Avoid race where child exits before stdout listeners are attached.
argv: [process.execPath, "-e", 'setTimeout(() => process.stdout.write("streamed"), 200)'],
timeoutMs: 10_000,
argv: [
process.execPath,
"-e",
`setTimeout(() => process.stdout.write("streamed"), ${OUTPUT_DELAY_MS})`,
],
timeoutMs: 2_000,
stdinMode: "pipe-closed",
captureOutput: false,
onStdout: (chunk) => {