Merge branch 'main' into max/lfe-3587-update-prompt-versions

langfuse · Jan 24, 2025 · d5fd31f · d5fd31f
2 parents b983d5f + 2cb1ea1
commit d5fd31f
Show file tree

Hide file tree

Showing 9 changed files with 21 additions and 16 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -1,5 +1,5 @@
 {
   "$schema": "node_modules/lerna/schemas/lerna-schema.json",
   "npmClient": "yarn",
-  "version": "3.32.0"
+  "version": "3.32.2"
 }