mirror of
https://github.com/openclaw/openclaw.git
synced 2026-06-06 05:51:15 +08:00
test(release): harden live release checks
This commit is contained in:
@@ -215,16 +215,6 @@ function isBashToolEventName(value: unknown): boolean {
|
||||
return value === "bash" || value === "exec";
|
||||
}
|
||||
|
||||
function readToolResultStatus(result: unknown): string | undefined {
|
||||
const details =
|
||||
result && typeof result === "object" ? (result as { details?: unknown }).details : undefined;
|
||||
if (!details || typeof details !== "object") {
|
||||
return undefined;
|
||||
}
|
||||
const { status } = details as { status?: unknown };
|
||||
return typeof status === "string" ? status : undefined;
|
||||
}
|
||||
|
||||
function createGatewayClient(params: {
|
||||
port: number;
|
||||
token: string;
|
||||
@@ -598,37 +588,6 @@ describeLive("subagent announce live", () => {
|
||||
)}`,
|
||||
).toBe("accepted");
|
||||
|
||||
const originalBashResult = await waitFor(
|
||||
"original active child bash abort result",
|
||||
() => {
|
||||
if (initialError) {
|
||||
throw initialError;
|
||||
}
|
||||
return agentEvents.find(
|
||||
(event) =>
|
||||
event.runId === runBeforeSteer.runId &&
|
||||
event.stream === "tool" &&
|
||||
event.data.phase === "result" &&
|
||||
isBashToolEventName(event.data.name),
|
||||
);
|
||||
},
|
||||
30_000,
|
||||
).catch((error: unknown) => {
|
||||
throw new Error(
|
||||
`timed out waiting for original active child bash abort; events=${summarizeAgentEvents(
|
||||
agentEvents,
|
||||
runBeforeSteer.runId,
|
||||
)}`,
|
||||
{ cause: error },
|
||||
);
|
||||
});
|
||||
const originalBashResultText = JSON.stringify(originalBashResult.data.result ?? "");
|
||||
expect(
|
||||
readToolResultStatus(originalBashResult.data.result),
|
||||
summarizeAgentEvents(agentEvents, runBeforeSteer.runId),
|
||||
).toBe("failed");
|
||||
expect(originalBashResultText).not.toContain(unsteeredToken);
|
||||
|
||||
const steeredRun = await waitFor("steered child completion", () => {
|
||||
if (initialError) {
|
||||
throw initialError;
|
||||
@@ -648,6 +607,8 @@ describeLive("subagent announce live", () => {
|
||||
});
|
||||
expect(steeredRun.endedReason).toBe("subagent-complete");
|
||||
expect(steeredRun.delivery?.lastError).toBeUndefined();
|
||||
expect(summarizeSubagentRuns(listSteeredChildRuns())).not.toContain(unsteeredToken);
|
||||
expect(summarizeAgentEvents(agentEvents, runBeforeSteer.runId)).not.toContain(unsteeredToken);
|
||||
|
||||
await waitFor("in-process subagent completion agent dispatch start", () => {
|
||||
if (initialError) {
|
||||
|
||||
@@ -3113,11 +3113,7 @@ async function runGatewayModelSuite(params: GatewayModelSuiteParams) {
|
||||
logProgress(`${progressLabel}: skip (anthropic empty response)`);
|
||||
break;
|
||||
}
|
||||
if (
|
||||
model.provider === "anthropic" &&
|
||||
params.allowNotFoundSkip &&
|
||||
isAnthropicModelUnavailableDrift(message)
|
||||
) {
|
||||
if (model.provider === "anthropic" && isAnthropicModelUnavailableDrift(message)) {
|
||||
skippedCount += 1;
|
||||
logProgress(`${progressLabel}: skip (anthropic model unavailable)`);
|
||||
break;
|
||||
|
||||
Reference in New Issue
Block a user