ewilliams28/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-08-28 13:26:04 -06:00
Code Issues Packages Projects Releases Wiki Activity

test: tolerate optional ACP cron live timeout

Browse Source
This commit is contained in:
Vincent Koc
2026-05-18 10:19:55 +08:00
parent 11d7499db1
commit 73ca3cf3c3
1 changed files with 31 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/gateway/gateway-acp-bind.live.test.ts
+31 -14
View File
@@ -975,20 +975,37 @@ describeLive("gateway live (ACP bind)", () => {
sessionKey: spawnedSessionKey,
});
lastCronProbeName = cronProbe.name;
await sendChatAndWait({
client,
sessionKey: originalSessionKey,
idempotencyKey: `idem-cron-${attempt}-${randomUUID()}`,
message: buildLiveCronProbeMessage({
agent: liveAgent,
argsJson: cronProbe.argsJson,
attempt,
exactReply: cronProbe.name,
}),
originatingChannel: "slack",
originatingTo: conversationId,
originatingAccountId: accountId,
});
try {
await sendChatAndWait({
client,
sessionKey: originalSessionKey,
idempotencyKey: `idem-cron-${attempt}-${randomUUID()}`,
message: buildLiveCronProbeMessage({
agent: liveAgent,
argsJson: cronProbe.argsJson,
attempt,
exactReply: cronProbe.name,
}),
originatingChannel: "slack",
originatingTo: conversationId,
originatingAccountId: accountId,
});
} catch (error) {
lastCronMismatch = error instanceof Error ? error.message : String(error);
logLiveStep(
`cron mcp turn failed after attempt ${String(attempt + 1)}: ${lastCronMismatch}`,
);
if (!requireCronMcpProbe) {
logLiveStep(
`cron mcp turn ${lastCronProbeName} failed; continuing after bind/image verification`,
);
break;
}
if (attempt === ACP_CRON_MCP_PROBE_MAX_ATTEMPTS - 1) {
throw error;
}
continue;
}
logLiveStep(`cron mcp turn completed (attempt ${String(attempt + 1)})`);
let cronHistory: Awaited<ReturnType<typeof waitForAssistantText>> | null = null;