LLM/moltbot
1
0
Fork 0
mirror of https://github.com/moltbot/moltbot.git synced 2026-03-30 01:06:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: stabilize low-profile parallel gate

Browse Source
This commit is contained in:
Peter Steinberger
2026-03-24 18:39:44 +00:00
parent 2383107711
commit f6b3377af2
2 changed files with 37 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
scripts/lib/format-generated-module.mjs
View File

@@ -1,5 +1,6 @@
import { spawnSync } from "node:child_process";
import fs from "node:fs";
import os from "node:os";
import path from "node:path";
export function formatGeneratedModule(source, { repoRoot, outputPath, errorLabel }) {
@@ -8,27 +9,33 @@ export function formatGeneratedModule(source, { repoRoot, outputPath, errorLabel
resolvedRepoRoot,
path.isAbsolute(outputPath) ? path.relative(resolvedRepoRoot, outputPath) : outputPath,
);
const formatterPath = path.relative(resolvedRepoRoot, resolvedOutputPath) || resolvedOutputPath;
const directFormatterPath = path.join(resolvedRepoRoot, "node_modules", ".bin", "oxfmt");
const useDirectFormatter = process.platform !== "win32" && fs.existsSync(directFormatterPath);
const command = useDirectFormatter ? directFormatterPath : "pnpm";
const args = useDirectFormatter
? ["--stdin-filepath", formatterPath]
: ["exec", "oxfmt", "--stdin-filepath", formatterPath];
const formatter = spawnSync(command, args, {
cwd: resolvedRepoRoot,
input: source,
encoding: "utf8",
// Windows requires a shell to launch package-manager shim scripts reliably.
...(process.platform === "win32" ? { shell: true } : {}),
});
if (formatter.status !== 0) {
const details =
formatter.stderr?.trim() ||
formatter.stdout?.trim() ||
formatter.error?.message ||
"unknown formatter failure";
throw new Error(`failed to format generated ${errorLabel}: ${details}`);
const tempDir = fs.mkdtempSync(path.join(os.tmpdir(), "openclaw-generated-format-"));
const tempOutputPath = path.join(tempDir, path.basename(resolvedOutputPath));
try {
fs.writeFileSync(tempOutputPath, source, "utf8");
const args = useDirectFormatter
? ["--write", tempOutputPath]
: ["exec", "oxfmt", "--write", tempOutputPath];
const formatter = spawnSync(command, args, {
cwd: resolvedRepoRoot,
encoding: "utf8",
// Windows requires a shell to launch package-manager shim scripts reliably.
...(process.platform === "win32" ? { shell: true } : {}),
});
if (formatter.status !== 0) {
const details =
formatter.stderr?.trim() ||
formatter.stdout?.trim() ||
formatter.error?.message ||
"unknown formatter failure";
throw new Error(`failed to format generated ${errorLabel}: ${details}`);
}
return fs.readFileSync(tempOutputPath, "utf8");
} finally {
fs.rmSync(tempDir, { recursive: true, force: true });
}
return formatter.stdout;
}

14
scripts/test-parallel.mjs
View File

@@ -55,6 +55,10 @@ const cleanupTempArtifacts = () => {
if (tempArtifactDir === null) {
return;
}
if (process.env.OPENCLAW_TEST_KEEP_TEMP_ARTIFACTS === "1") {
console.error(`[test-parallel] keeping temp artifacts at ${tempArtifactDir}`);
return;
}
fs.rmSync(tempArtifactDir, { recursive: true, force: true });
tempArtifactDir = null;
};
@@ -455,12 +459,13 @@ const channelIsolatedEntries = channelIsolatedFiles.map((file) => ({
name: `${path.basename(file, ".test.ts")}-channels-isolated`,
args: ["vitest", "run", "--config", "vitest.channels.config.ts", "--pool=forks", file],
}));
const defaultUnitFastLaneCount = isCI && !isWindows ? 3 : 1;
const defaultUnitFastLaneCount = testProfile === "low" ? 8 : isCI && !isWindows ? 3 : 1;
const unitFastLaneCount = Math.max(
1,
parseEnvNumber("OPENCLAW_TEST_UNIT_FAST_LANES", defaultUnitFastLaneCount),
);
const defaultUnitFastBatchTargetMs = isCI && !isWindows ? 45_000 : 0;
const defaultUnitFastBatchTargetMs =
testProfile === "low" ? 10_000 : isCI && !isWindows ? 45_000 : 0;
const unitFastBatchTargetMs = parseEnvNumber(
"OPENCLAW_TEST_UNIT_FAST_BATCH_TARGET_MS",
defaultUnitFastBatchTargetMs,
@@ -1665,7 +1670,10 @@ if (serialPrefixRuns.length > 0) {
if (failedSerialPrefix !== undefined) {
process.exit(failedSerialPrefix);
}
const deferredRunConcurrency = isMacMiniProfile ? 3 : testProfile === "low" ? 2 : undefined;
// Low-profile runs favor stability over overlap once we leave the shared
// unit-fast batches; the isolated memory-heavy lanes can still trip over
// each other when two singleton Vitest processes overlap.
const deferredRunConcurrency = isMacMiniProfile ? 3 : testProfile === "low" ? 1 : undefined;
const failedDeferredParallel = isMacMiniProfile
? await runEntriesWithLimit(deferredParallelRuns, passthroughOptionArgs, deferredRunConcurrency)
: deferredRunConcurrency