diff --git a/src/lib/langfuse/trace-proxy-request.ts b/src/lib/langfuse/trace-proxy-request.ts index 2d4ec6bc3..09a23f7fd 100644 --- a/src/lib/langfuse/trace-proxy-request.ts +++ b/src/lib/langfuse/trace-proxy-request.ts @@ -408,7 +408,7 @@ export async function traceProxyRequest(ctx: TraceContext): Promise { ); // Explicitly set trace-level input/output (propagateAttributes does not support these) - rootSpan.updateTrace({ + rootSpan.setTraceIO({ input: actualRequestBody, output: actualResponseBody, }); diff --git a/tests/unit/langfuse/langfuse-trace.test.ts b/tests/unit/langfuse/langfuse-trace.test.ts index fb0871f62..3c3c105f8 100644 --- a/tests/unit/langfuse/langfuse-trace.test.ts +++ b/tests/unit/langfuse/langfuse-trace.test.ts @@ -25,11 +25,11 @@ const mockEventObs: any = { end: mockEventEnd, }; -const mockUpdateTrace = vi.fn(); +const mockSetTraceIO = vi.fn(); const mockRootSpan = { startObservation: vi.fn(), - updateTrace: mockUpdateTrace, + setTraceIO: mockSetTraceIO, end: mockSpanEnd, }; @@ -537,7 +537,7 @@ describe("traceProxyRequest", () => { (c: unknown[]) => c[0] === "llm-call" ); expect(llmCall[1].output).toEqual(expectedOutput); - expect(mockRootSpan.updateTrace).toHaveBeenCalledWith( + expect(mockRootSpan.setTraceIO).toHaveBeenCalledWith( expect.objectContaining({ output: expectedOutput, }) @@ -575,7 +575,7 @@ describe("traceProxyRequest", () => { (c: unknown[]) => c[0] === "llm-call" ); expect(llmCall[1].output).toEqual(expectedOutput); - expect(mockRootSpan.updateTrace).toHaveBeenCalledWith( + expect(mockRootSpan.setTraceIO).toHaveBeenCalledWith( expect.objectContaining({ output: expectedOutput, }) @@ -602,7 +602,7 @@ describe("traceProxyRequest", () => { ); }); - test("should set trace-level input/output via updateTrace with actual bodies", async () => { + test("should set trace-level input/output via setTraceIO with actual bodies", async () => { const { traceProxyRequest } = await import("@/lib/langfuse/trace-proxy-request"); const responseBody = { result: "ok" }; @@ -616,7 +616,7 @@ describe("traceProxyRequest", () => { costUsd: "0.05", }); - expect(mockUpdateTrace).toHaveBeenCalledWith({ + expect(mockSetTraceIO).toHaveBeenCalledWith({ input: expect.objectContaining({ model: "claude-sonnet-4-20250514", messages: expect.any(Array), @@ -882,8 +882,8 @@ describe("traceProxyRequest", () => { const rootCall = mockStartObservation.mock.calls[0]; expect(rootCall[1].input).toEqual(JSON.parse(forwardedBody)); - // updateTrace should also use forwarded body - expect(mockUpdateTrace).toHaveBeenCalledWith({ + // setTraceIO should also use forwarded body + expect(mockSetTraceIO).toHaveBeenCalledWith({ input: JSON.parse(forwardedBody), output: { ok: true }, });