chore(langchain/v1): patch changes

* #9131
* #9093
* #9081
* #9069
* #9059
* #9057
* #9028
* #8978
* #8974
* #8966
* #8938
* #8932
* #8442
* #8863
* #8887
* #8849
* #8696
* #8850
* #8837
* #8719
* #8695
* #8634

Author: hntrl

libs/langchain-classic/src/chains/openai_functions/openapi.ts

@@ -189,9 +189,10 @@ export function convertOpenAPISchemaToJSONSchema(
     );
   }
   if (schema.type === "array") {
+    const openAPIItems = spec.getSchema(schema.items ?? {});
     return {
       type: "array",
-      items: convertOpenAPISchemaToJSONSchema(schema.items ?? {}, spec),
+      items: convertOpenAPISchemaToJSONSchema(openAPIItems, spec),
       minItems: schema.minItems,
       maxItems: schema.maxItems,
     } as JsonSchema7ArrayType;

libs/langchain-classic/src/chains/openai_functions/tests/openapi.test.ts

@@ -1,4 +1,4 @@
-import { test, expect } from "vitest";
+import { test, expect } from "@jest/globals";
 
 import { OpenAPIV3, OpenAPIV3_1 } from "openapi-types";
 import {
@@ -69,6 +69,21 @@ test("Test convert OpenAPI params to JSON Schema", async () => {
                 },
               },
             },
+            {
+              name: "refParam",
+              in: "query",
+              schema: {
+                $ref: "#/components/schemas/RefObject",
+              },
+            },
+            {
+              name: "refArrayParam",
+              in: "query",
+              schema: {
+                type: "array",
+                items: { $ref: "#/components/schemas/RefObject" },
+              },
+            },
             {
               name: "nestedObjectInArrayParam",
               in: "query",
@@ -147,6 +162,21 @@ test("Test convert OpenAPI params to JSON Schema", async () => {
         },
       },
     },
+    components: {
+      schemas: {
+        RefObject: {
+          type: "object",
+          properties: {
+            foo: {
+              type: "string",
+            },
+            bar: {
+              type: "number",
+            },
+          },
+        },
+      },
+    },
   });
 
   const createWidget = spec.getOperation(
@@ -225,6 +255,26 @@ test("Test convert OpenAPI params to JSON Schema", async () => {
   expect(typedStringArrayParamSchema.items).not.toBeUndefined();
   expectType("string", typedStringArrayParamSchema.items);
 
+  const refParamSchema = convertOpenAPISchemaToJSONSchema(
+    getParamSchema(createWidget, "refParam"),
+    spec
+  );
+  const typedRefParamSchema = expectType("object", refParamSchema);
+  expectType("string", typedRefParamSchema.properties.foo);
+  expectType("number", typedRefParamSchema.properties.bar);
+
+  const refArrayParamSchema = convertOpenAPISchemaToJSONSchema(
+    getParamSchema(createWidget, "refArrayParam"),
+    spec
+  );
+  const typedRefArrayParamSchema = expectType("array", refArrayParamSchema);
+  const typedRefArrayParamSchemaItems = expectType(
+    "object",
+    typedRefArrayParamSchema.items
+  );
+  expectType("string", typedRefArrayParamSchemaItems.properties.foo);
+  expectType("number", typedRefArrayParamSchemaItems.properties.bar);
+
   const nestedObjectInArrayParamSchema = convertOpenAPISchemaToJSONSchema(
     getParamSchema(createWidget, "nestedObjectInArrayParam"),
     spec

libs/langchain-core/src/callbacks/manager.ts

@@ -1251,12 +1251,18 @@ export class CallbackManager
         if (tracingV2Enabled) {
           const tracerV2 = new LangChainTracer();
           callbackManager.addHandler(tracerV2, true);
-
-          // handoff between langchain and langsmith/traceable
-          // override the parent run ID
-          callbackManager._parentRunId =
-            LangChainTracer.getTraceableRunTree()?.id ??
-            callbackManager._parentRunId;
+        }
+      }
+      if (tracingV2Enabled) {
+        // handoff between langchain and langsmith/traceable
+        // override the parent run ID
+        const implicitRunTree = LangChainTracer.getTraceableRunTree();
+        if (implicitRunTree && callbackManager._parentRunId === undefined) {
+          callbackManager._parentRunId = implicitRunTree.id;
+          const tracerV2 = callbackManager.handlers.find(
+            (handler) => handler.name === "langchain_tracer"
+          ) as LangChainTracer | undefined;
+          tracerV2?.updateFromRunTree(implicitRunTree);
         }
       }
     }

libs/langchain-core/src/tracers/tests/langsmith_interop.int.test.ts

@@ -4,6 +4,7 @@ import { traceable } from "langsmith/traceable";
 import { RunnableLambda } from "../../runnables/base.js";
 import { BaseMessage, HumanMessage } from "../../messages/index.js";
 import { awaitAllCallbacks } from "../../singletons/callbacks.js";
+import { LangChainTracer } from "../tracer_langchain.js";
 
 test("traceables double nested within runnables with batching", async () => {
   const aiGreet = traceable(
@@ -27,3 +28,67 @@ test("traceables double nested within runnables with batching", async () => {
 
   await awaitAllCallbacks();
 });
+
+test("deep nesting with manual tracer passed", async () => {
+  const aiGreet = traceable(
+    async (msg: BaseMessage) => {
+      const child = RunnableLambda.from(async () => {
+        const grandchild = RunnableLambda.from(async () => {
+          const greatGrandchild = traceable(
+            async () => {
+              const greatGreatGrandchild = RunnableLambda.from(async () => {
+                return [
+                  new HumanMessage({ content: "From great great grandchild!" }),
+                ];
+              }).withConfig({ runName: "greatGreatGrandchild" });
+              return greatGreatGrandchild.invoke({});
+            },
+            { name: "greatGrandchild", tracingEnabled: true }
+          );
+          return greatGrandchild({});
+        }).withConfig({ runName: "grandchild" });
+        return grandchild.invoke({});
+      }).withConfig({ runName: "child" });
+      return child.invoke([msg]);
+    },
+    { name: "aiGreet", tracingEnabled: true }
+  );
+
+  const parent = RunnableLambda.from(async () => {
+    return aiGreet(new HumanMessage({ content: "Hello!" }));
+  }).withConfig({ runName: "parent" });
+
+  await parent.invoke(
+    {},
+    {
+      callbacks: [new LangChainTracer()],
+    }
+  );
+
+  await awaitAllCallbacks();
+});
+
+test("runnable nested within a traceable with manual tracer passed", async () => {
+  const child = RunnableLambda.from(async () => {
+    const grandchild = RunnableLambda.from(async () => {
+      return [new HumanMessage({ content: "From grandchild!" })];
+    }).withConfig({ runName: "grandchild" });
+    return grandchild.invoke({});
+  }).withConfig({ runName: "child" });
+
+  const parent = traceable(
+    async () => {
+      return child.invoke(
+        {},
+        {
+          callbacks: [new LangChainTracer()],
+        }
+      );
+    },
+    { name: "parent", tracingEnabled: true }
+  );
+
+  await parent();
+
+  await awaitAllCallbacks();
+});