diff --git a/integration-test/langfuse-integration-vercel.spec.ts b/integration-test/langfuse-integration-vercel.spec.ts index 17240a25..92b9bbd6 100644 --- a/integration-test/langfuse-integration-vercel.spec.ts +++ b/integration-test/langfuse-integration-vercel.spec.ts @@ -314,8 +314,6 @@ describe("langfuse-integration-vercel", () => { }, }); - console.log(JSON.stringify(result.object.recipe, null, 2)); - await sdk.shutdown(); // Fetch trace @@ -404,8 +402,6 @@ describe("langfuse-integration-vercel", () => { currentObject = partialObject; } - console.log(currentObject); - await sdk.shutdown(); // Fetch trace diff --git a/langfuse-core/package.json b/langfuse-core/package.json index 8aeef4ca..a52738d2 100644 --- a/langfuse-core/package.json +++ b/langfuse-core/package.json @@ -1,6 +1,6 @@ { "name": "langfuse-core", - "version": "3.32.0", + "version": "3.32.2", "engines": { "node": ">=18" }, diff --git a/langfuse-langchain/package.json b/langfuse-langchain/package.json index 382d0733..797a1312 100644 --- a/langfuse-langchain/package.json +++ b/langfuse-langchain/package.json @@ -1,6 +1,6 @@ { "name": "langfuse-langchain", - "version": "3.32.0", + "version": "3.32.2", "engines": { "node": ">=18" }, @@ -39,8 +39,8 @@ ], "gitHead": "d6d5a92736bca6a2beee4a894d23f72cc5b2f0ed", "dependencies": { - "langfuse": "^3.32.0", - "langfuse-core": "^3.32.0" + "langfuse": "^3.32.2", + "langfuse-core": "^3.32.2" }, "peerDependencies": { "langchain": ">=0.0.157 <0.4.0" diff --git a/langfuse-langchain/src/callback.ts b/langfuse-langchain/src/callback.ts index e7108cb9..b312fe3b 100644 --- a/langfuse-langchain/src/callback.ts +++ b/langfuse-langchain/src/callback.ts @@ -23,6 +23,8 @@ import type { Document } from "@langchain/core/documents"; import type { ChatPromptClient, LangfuseSpanClient, LangfuseTraceClient, TextPromptClient } from "langfuse-core"; +const LANGSMITH_HIDDEN_TAG = "langsmith:hidden"; + export type LlmMessage = { role: string; content: BaseMessageFields["content"]; @@ -216,6 +218,7 @@ export class CallbackHandler extends BaseCallbackHandler { metadata: this.joinTagsAndMetaData(tags, metadata), input: finalInput, version: this.version, + level: tags && tags.includes(LANGSMITH_HIDDEN_TAG) ? "DEBUG" : undefined, }); // If there's no parent run, this is a top-level chain execution. @@ -414,6 +417,7 @@ export class CallbackHandler extends BaseCallbackHandler { modelParameters: modelParameters, version: this.version, prompt: registeredPrompt, + level: tags && tags.includes(LANGSMITH_HIDDEN_TAG) ? "DEBUG" : undefined, }); } @@ -500,6 +504,7 @@ export class CallbackHandler extends BaseCallbackHandler { input: input, metadata: this.joinTagsAndMetaData(tags, metadata), version: this.version, + level: tags && tags.includes(LANGSMITH_HIDDEN_TAG) ? "DEBUG" : undefined, }); } catch (e) { this._log(e); @@ -526,6 +531,7 @@ export class CallbackHandler extends BaseCallbackHandler { input: query, metadata: this.joinTagsAndMetaData(tags, metadata), version: this.version, + level: tags && tags.includes(LANGSMITH_HIDDEN_TAG) ? "DEBUG" : undefined, }); } catch (e) { this._log(e); diff --git a/langfuse-node/package.json b/langfuse-node/package.json index 11374a1f..7cf16ebd 100644 --- a/langfuse-node/package.json +++ b/langfuse-node/package.json @@ -1,6 +1,6 @@ { "name": "langfuse-node", - "version": "3.32.0", + "version": "3.32.2", "scripts": { "prepublishOnly": "cd .. && yarn build" }, @@ -33,7 +33,7 @@ }, "dependencies": { "axios": "^1.7.4", - "langfuse-core": "^3.32.0" + "langfuse-core": "^3.32.2" }, "devDependencies": { "@types/node": "^22.7.4", diff --git a/langfuse-vercel/package.json b/langfuse-vercel/package.json index cab50d23..9bba8bfe 100644 --- a/langfuse-vercel/package.json +++ b/langfuse-vercel/package.json @@ -1,6 +1,6 @@ { "name": "langfuse-vercel", - "version": "3.32.0", + "version": "3.32.2", "engines": { "node": ">=18" }, @@ -39,8 +39,8 @@ ], "gitHead": "d6d5a92736bca6a2beee4a894d23f72cc5b2f0ed", "dependencies": { - "langfuse": "^3.32.0", - "langfuse-core": "^3.32.0" + "langfuse": "^3.32.2", + "langfuse-core": "^3.32.2" }, "peerDependencies": { "ai": ">=3.2.44" diff --git a/langfuse-vercel/src/LangfuseExporter.ts b/langfuse-vercel/src/LangfuseExporter.ts index 9a5ec347..d144a674 100644 --- a/langfuse-vercel/src/LangfuseExporter.ts +++ b/langfuse-vercel/src/LangfuseExporter.ts @@ -55,6 +55,9 @@ export class LangfuseExporter implements SpanExporter { this.processTraceSpans(traceId, spans); } + // Schedule a flush. Necessary to ensure event delivery in Vercel Cloud Functions with streaming responses + this.langfuse.flushAsync(); + const successCode: ExportResultCode.SUCCESS = 0; // Do not use enum directly to avoid adding a dependency on the enum resultCallback({ code: successCode }); diff --git a/langfuse/package.json b/langfuse/package.json index 3d1986e6..4ebf9fe3 100644 --- a/langfuse/package.json +++ b/langfuse/package.json @@ -1,6 +1,6 @@ { "name": "langfuse", - "version": "3.32.0", + "version": "3.32.2", "engines": { "node": ">=18" }, @@ -37,7 +37,7 @@ "Readme.md" ], "dependencies": { - "langfuse-core": "^3.32.0" + "langfuse-core": "^3.32.2" }, "gitHead": "d6d5a92736bca6a2beee4a894d23f72cc5b2f0ed", "devDependencies": { diff --git a/lerna.json b/lerna.json index 9de0085f..5b5ad7bc 100644 --- a/lerna.json +++ b/lerna.json @@ -1,5 +1,5 @@ { "$schema": "node_modules/lerna/schemas/lerna-schema.json", "npmClient": "yarn", - "version": "3.32.0" + "version": "3.32.2" }