github/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-10 06:52:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Revert "fix(gateway): set explicit chat timeouts for mesh gateway calls"

Browse Source 
This reverts commit c529e6005a.
This commit is contained in:
Peter Steinberger
2026-02-17 02:25:31 +01:00
parent 563df56389
commit 83392d3927
1 changed files with 0 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/auto-reply/reply/commands-mesh.ts
View File

@@ -21,10 +21,6 @@ type ParsedMeshCommand =
const meshPlanCache = new Map<string, CachedMeshPlan>(); const meshPlanCache = new Map<string, CachedMeshPlan>();
const MAX_CACHED_MESH_PLANS = 200; const MAX_CACHED_MESH_PLANS = 200;
const MESH_PLAN_CALL_TIMEOUT_MS = 120_000;
const MESH_RUN_CALL_TIMEOUT_MS = 15 * 60_000;
const MESH_STATUS_CALL_TIMEOUT_MS = 15_000;
const MESH_RETRY_CALL_TIMEOUT_MS = 15 * 60_000;
function trimMeshPlanCache() { function trimMeshPlanCache() {
if (meshPlanCache.size <= MAX_CACHED_MESH_PLANS) { if (meshPlanCache.size <= MAX_CACHED_MESH_PLANS) {
@@ -225,7 +221,6 @@ export const handleMeshCommand: CommandHandler = async (params, allowTextCommand
agentId: params.agentId ?? "main", agentId: params.agentId ?? "main",
}, },
...commonGateway, ...commonGateway,
timeoutMs: MESH_PLAN_CALL_TIMEOUT_MS,
}); });
putCachedPlan(params, planResp.plan); putCachedPlan(params, planResp.plan);
const sourceLine = planResp.source ? `\nPlanner source: ${planResp.source}` : ""; const sourceLine = planResp.source ? `\nPlanner source: ${planResp.source}` : "";
@@ -262,7 +257,6 @@ export const handleMeshCommand: CommandHandler = async (params, allowTextCommand
agentId: params.agentId ?? "main", agentId: params.agentId ?? "main",
}, },
...commonGateway, ...commonGateway,
timeoutMs: MESH_PLAN_CALL_TIMEOUT_MS,
}); });
putCachedPlan(params, planResp.plan); putCachedPlan(params, planResp.plan);
runPlan = planResp.plan; runPlan = planResp.plan;
@@ -285,7 +279,6 @@ export const handleMeshCommand: CommandHandler = async (params, allowTextCommand
plan: runPlan, plan: runPlan,
}, },
...commonGateway, ...commonGateway,
timeoutMs: MESH_RUN_CALL_TIMEOUT_MS,
}); });
return { return {
@@ -312,7 +305,6 @@ export const handleMeshCommand: CommandHandler = async (params, allowTextCommand
method: "mesh.status", method: "mesh.status",
params: { runId: parsed.runId }, params: { runId: parsed.runId },
...commonGateway, ...commonGateway,
timeoutMs: MESH_STATUS_CALL_TIMEOUT_MS,
}); });
return { return {
shouldContinue: false, shouldContinue: false,
@@ -339,7 +331,6 @@ export const handleMeshCommand: CommandHandler = async (params, allowTextCommand
...(parsed.stepIds && parsed.stepIds.length > 0 ? { stepIds: parsed.stepIds } : {}), ...(parsed.stepIds && parsed.stepIds.length > 0 ? { stepIds: parsed.stepIds } : {}),
}, },
...commonGateway, ...commonGateway,
timeoutMs: MESH_RETRY_CALL_TIMEOUT_MS,
}); });
return { return {
shouldContinue: false, shouldContinue: false,