diff options
| author | Adam Malczewski <[email protected]> | 2026-06-05 21:19:45 +0900 |
|---|---|---|
| committer | Adam Malczewski <[email protected]> | 2026-06-05 21:19:45 +0900 |
| commit | 4283d1f8a0bc3953e65962a2364c903d0015f047 (patch) | |
| tree | 4de5d2d2c1114301f03236b6dfc98a638a7c61c0 /packages/kernel/src/runtime/dispatch.ts | |
| parent | 368be032ef57638b558db659d70bfac00cb95cdd (diff) | |
| download | dispatch-4283d1f8a0bc3953e65962a2364c903d0015f047.tar.gz dispatch-4283d1f8a0bc3953e65962a2364c903d0015f047.zip | |
feat(kernel): listModels/ModelInfo + per-turn cwd contracts; add transport-contract wire package
Diffstat (limited to 'packages/kernel/src/runtime/dispatch.ts')
| -rw-r--r-- | packages/kernel/src/runtime/dispatch.ts | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/packages/kernel/src/runtime/dispatch.ts b/packages/kernel/src/runtime/dispatch.ts index 1ba0849..d168319 100644 --- a/packages/kernel/src/runtime/dispatch.ts +++ b/packages/kernel/src/runtime/dispatch.ts @@ -17,6 +17,7 @@ export async function executeToolCall( conversationId: string, turnId: string, toolSpan?: Span, + cwd?: string, ): Promise<ToolResult> { if (tool === undefined) { return { content: `Unknown tool: ${call.name}`, isError: true }; @@ -31,6 +32,7 @@ export async function executeToolCall( emit(toolOutputEvent(conversationId, turnId, call.id, data, stream)); }, log: toolSpan?.log ?? createNoopLogger(), + ...(cwd !== undefined ? { cwd } : {}), }; try { return await tool.execute(call.input, ctx); @@ -54,6 +56,7 @@ export function createStepDispatcher( conversationId: string, turnId: string, toolSpans: Map<string, Span>, + cwd?: string, ): StepDispatcher { let activeCount = 0; let unsafeRunning = false; @@ -91,6 +94,7 @@ export function createStepDispatcher( conversationId, turnId, tcSpan, + cwd, ); activeCount--; if (entry.tool?.concurrencySafe === false) unsafeRunning = false; |
