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

fix(agents): extend subagent announce timeout

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-06 03:03:31 +01:00
parent 06b154a6df
commit b0d9d1d2da
2 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/agents/subagent-announce-delivery.ts
View File

@@ -41,7 +41,7 @@ import { type AnnounceQueueItem, enqueueAnnounce } from "./subagent-announce-que
import { getSubagentDepthFromSessionStore } from "./subagent-depth.js";
import type { SpawnSubagentMode } from "./subagent-spawn.js";
const DEFAULT_SUBAGENT_ANNOUNCE_TIMEOUT_MS = 90_000;
const DEFAULT_SUBAGENT_ANNOUNCE_TIMEOUT_MS = 120_000;
const MAX_TIMER_SAFE_TIMEOUT_MS = 2_147_000_000;
type SubagentAnnounceDeliveryDeps = {

18
src/agents/subagent-announce.timeout.test.ts
View File

@@ -129,7 +129,7 @@ vi.mock("./subagent-announce-delivery.js", () => ({
Math.max(1, Math.floor(configOverride.agents.defaults.subagents.announceTimeoutMs)),
2_147_000_000,
)
: 90_000;
: 120_000;
const retryDelaysMs =
process.env.OPENCLAW_TEST_FAST === "1" ? [8, 16, 32] : [5_000, 10_000, 20_000];
let retryIndex = 0;
@@ -162,7 +162,7 @@ vi.mock("./subagent-announce-delivery.js", () => ({
resolveSubagentAnnounceTimeoutMs: (cfg: typeof configOverride) => {
const configured = cfg.agents?.defaults?.subagents?.announceTimeoutMs;
if (typeof configured !== "number" || !Number.isFinite(configured)) {
return 90_000;
return 120_000;
}
return Math.min(Math.max(1, Math.floor(configured)), 2_147_000_000);
},
@@ -278,27 +278,27 @@ describe("subagent announce timeout config", () => {
fallbackRequesterResolution = null;
});
it("uses 90s timeout by default for direct announce agent call", async () => {
it("uses 120s timeout by default for direct announce agent call", async () => {
await runAnnounceFlowForTest("run-default-timeout");
const directAgentCall = findGatewayCall(
(call) => call.method === "agent" && call.expectFinal === true,
);
expect(directAgentCall?.timeoutMs).toBe(90_000);
expect(directAgentCall?.timeoutMs).toBe(120_000);
});
it("honors configured announce timeout for direct announce agent call", async () => {
setConfiguredAnnounceTimeout(90_000);
setConfiguredAnnounceTimeout(120_000);
await runAnnounceFlowForTest("run-config-timeout-agent");
const directAgentCall = findGatewayCall(
(call) => call.method === "agent" && call.expectFinal === true,
);
expect(directAgentCall?.timeoutMs).toBe(90_000);
expect(directAgentCall?.timeoutMs).toBe(120_000);
});
it("honors configured announce timeout for completion direct agent call", async () => {
setConfiguredAnnounceTimeout(90_000);
setConfiguredAnnounceTimeout(120_000);
await runAnnounceFlowForTest("run-config-timeout-send", {
requesterOrigin: {
channel: "discord",
@@ -310,7 +310,7 @@ describe("subagent announce timeout config", () => {
const completionDirectAgentCall = findGatewayCall(
(call) => call.method === "agent" && call.expectFinal === true,
);
expect(completionDirectAgentCall?.timeoutMs).toBe(90_000);
expect(completionDirectAgentCall?.timeoutMs).toBe(120_000);
});
it("retries gateway timeout for externally delivered completion announces before giving up", async () => {
@@ -320,7 +320,7 @@ describe("subagent announce timeout config", () => {
if (request.method === "chat.history") {
return { messages: [] };
}
throw new Error("gateway timeout after 90000ms");
throw new Error("gateway timeout after 120000ms");
};
const announcePromise = runAnnounceFlowForTest("run-completion-timeout-retry", {