ceos/opencode
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(core): disable mcp tool call timeout

Browse source
This commit is contained in:
Aiden Cline 2026-07-03 12:25:09 -05:00
commit c0413cdefa
1 changed files with 6 additions and 28 deletions
Download patch file Download diff file Expand all files Collapse all files

34
packages/core/src/mcp/client.ts
View file

@ -32,7 +32,7 @@ import { InstallationVersion } from "../installation/version"
const DEFAULT_STARTUP_TIMEOUT = 30_000
const DEFAULT_REQUEST_TIMEOUT = 30_000
const ELICITATION_PROGRESS_INTERVAL = 10_000
const TOOL_CALL_TIMEOUT = 2_147_483_647
type Transport = StdioClientTransport | StreamableHTTPClientTransport
@ -183,31 +183,9 @@ export const connect = Effect.fnUntraced(function* (
Promise.resolve({ roots: [{ uri: pathToFileURL(directory).href }] }),
)
if (elicitation) {
client.setRequestHandler(ElicitRequestSchema, async (request, extra) => {
const progressToken = extra._meta?.progressToken
const started = Date.now()
// Human input can exceed the server's request timeout; progress keeps cooperative callers alive.
const sendProgress = () => {
if (progressToken === undefined) return
void extra
.sendNotification({
method: "notifications/progress",
params: {
progressToken,
progress: Date.now() - started,
message: "Waiting for user response",
},
})
.catch(() => undefined)
}
const interval = progressToken === undefined ? undefined : setInterval(sendProgress, ELICITATION_PROGRESS_INTERVAL)
sendProgress()
try {
return await Effect.runPromise(elicitation.create({ server, params: request.params, signal: extra.signal }))
} finally {
if (interval !== undefined) clearInterval(interval)
}
})
client.setRequestHandler(ElicitRequestSchema, (request, extra) =>
Effect.runPromise(elicitation.create({ server, params: request.params, signal: extra.signal })),
)
client.setNotificationHandler(ElicitationCompleteNotificationSchema, (notification) =>
Effect.runPromise(elicitation.complete({ server, elicitationID: notification.params.elicitationId })),
)
@ -304,8 +282,8 @@ export const connect = Effect.fnUntraced(function* (
client.callTool(
{ name: input.name, arguments: input.args ?? {} },
CallToolResultSchema,
// Keep progress tokens available without imposing a client timeout on tool execution.
{ signal, resetTimeoutOnProgress: true, onprogress: () => {} },
// The SDK does not support disabling request timeouts; use the setTimeout max.
{ signal, timeout: TOOL_CALL_TIMEOUT, resetTimeoutOnProgress: true, onprogress: () => {} },
),
catch: (error) => (error instanceof Error ? error : new Error(String(error))),
}).pipe(