diff --git a/src/genai/instrumentations/langchain/langchainTraceInstrumentor.ts b/src/genai/instrumentations/langchain/langchainTraceInstrumentor.ts index ae6ebae..a8bb501 100644 --- a/src/genai/instrumentations/langchain/langchainTraceInstrumentor.ts +++ b/src/genai/instrumentations/langchain/langchainTraceInstrumentor.ts @@ -11,7 +11,7 @@ import { InstrumentationModuleDefinition, isWrapped, } from "@opentelemetry/instrumentation"; -import type { LangChainTracer } from "./tracer.js"; +import { LangChainTracer } from "./tracer.js"; type CallbackManagerModuleType = typeof CallbackManagerModule; type LangChainTracerCtor = new (tracer: Tracer) => LangChainTracer; @@ -21,10 +21,14 @@ class LangChainTraceInstrumentorImpl extends InstrumentationBase { - this._tracerCtor = m.LangChainTracer; - }, - (err) => { - diag.error( - `[LangChainTraceInstrumentor] Failed to load LangChainTracer: ${err instanceof Error ? err.message : String(err)}`, - ); - }, - ); - // eslint-disable-next-line @typescript-eslint/no-this-alias const instrumentor = this; this._wrap(CallbackManager, "_configureSync", (original) => { @@ -114,12 +102,8 @@ class LangChainTraceInstrumentorImpl extends InstrumentationBase ) { - if (instrumentor._tracerCtor) { - args[0] = addTracerToHandlers(instrumentor.otelTracer, args[0], instrumentor._tracerCtor); - diag.debug("[LangChainTraceInstrumentor] _configureSync wrapped to add LangChainTracer"); - } else { - diag.debug("[LangChainTraceInstrumentor] LangChainTracer not yet loaded, skipping"); - } + args[0] = addTracerToHandlers(instrumentor.otelTracer, args[0], instrumentor._tracerCtor); + diag.debug("[LangChainTraceInstrumentor] _configureSync wrapped to add LangChainTracer"); return original.apply(this, args); }; });