)hSrSSKrSSKrSSKJr SSKJr SSKJr SSK J r SSK J r Sr"SS\ 5r"SS5rg!\a5 \R "S \S S 9 "S S 5r "SS5r "SS5rSrNPf=f)z8OpenTelemetry span processor and exporter for LangSmith.N)Optional)urljoin)utils)OTLPSpanExporter)BatchSpanProcessorTwOpenTelemetry packages are not installed. Install optional OpenTelemetry dependencies with: pip install langsmith[otel]) stacklevelc\rSrSrSrSrSrg)rzMock otlp span exporter class.c[S5ezMock init method.r ImportErrorselfargskwargss U/root/34ku/venv/lib/python3.13/site-packages/langsmith/integrations/otel/processor.py__init__OTLPSpanExporter.__init__. N__name__ __module__ __qualname____firstlineno____doc__r__static_attributes__rrrrrs , rrc\rSrSrSrSrSrg)r#z Mock batch span processor class.c[S5errrs rrBatchSpanProcessor.__init__&rrrNrrrrrr#s . rrc(\rSrSrSr\S5rSrg)trace.zMock trace class.c[S5e)z Mock get tracer provider method.rrrrrget_tracer_providertrace.get_tracer_provider1s. rrN)rrrrr staticmethodr*r!rrrr'r'.s    rr'Fc n^\rSrSrSrS S\\S\\S\\S\\\\44U4SjjjrSr U=r $) OtelExporter=aA subclass of OTLPSpanExporter configured for LangSmith. Environment Variables: - LANGSMITH_API_KEY: Your LangSmith API key. - LANGSMITH_ENDPOINT: Base URL for LangSmith API (defaults to https://api.smith.langchain.com). - LANGSMITH_PROJECT: Project identifier. urlapi_keyprojectheadersc >[R"S5nURS5(dUS- nU=(d [US5nU=(d [R"S5nU=(d [R "5nU=(d 0nU(d [ S5eU(dSn[R"S5 SU0UEnU(aX8S'X0l [T U],"S XxS .UD6 g) aInitialize the OtelExporter. Args: url: OTLP endpoint URL. Defaults to {LANGSMITH_ENDPOINT}/otel/v1/traces. api_key: LangSmith API key. Defaults to LANGSMITH_API_KEY env var. parent: Parent identifier (e.g., "project_name:test"). Defaults to LANGSMITH_PARENT env var. headers: Additional headers to include in requests. **kwargs: Additional arguments passed to OTLPSpanExporter. N/zotel/v1/tracesz`API key is required. Provide it via api_key parameter or LANGSMITH_API_KEY environment variable.defaultzpNo project specified, using default. Configure with LANGSMITH_PROJECT environment variable or project parameter.z x-api-keyzLangsmith-Project)endpointr3r) ls_utils get_api_urlendswithr get_api_keyget_tracer_project ValueErrorlogginginfor2superr) rr0r1r2r3rbase_urlr7exporter_headers __class__s rrOtelExporter.__init__Fs$''-  %% OH='(,<=7X11$7:X88:-R:  G LL%     4;0 1  O(OOr)r2)NNNN) rrrrr rstrdictrr! __classcell__)rCs@rr.r.=se"!%!%,0 3P c]3P#3P# 3P $sCx.) 3P3Prr.c \rSrSrSrSS\\S\\S\\S\\\\4S\\4 S jjr SS jr S r S r SS jr \S5r\S5rSrg)OtelSpanProcessor|aA span processor for adding LangSmith to OpenTelemetry setups. This class combines the OtelExporter and BatchSpanProcessor into a single processor that can be added to any TracerProvider. Use this when: 1. You already have OpenTelemetry initialized with other tools 2. You want to add LangSmith alongside existing OTEL exporters Examples: # Fresh OpenTelemetry setup (LangSmith only): from langsmith.integrations.otel import configure configure(api_key="your-key", project="your-project") # Add LangSmith to existing OpenTelemetry setup: from opentelemetry import trace from langsmith.integrations.otel.processor import OtelSpanProcessor # Get your existing TracerProvider (already set by other tools) provider = trace.get_tracer_provider() # Add LangSmith processor alongside existing processors langsmith_processor = OtelSpanProcessor( project="your-project", ) provider.add_span_processor(langsmith_processor) Nr1r2r0r3 SpanProcessorcSnU(aURS5S3n[XaX$S9Ul[(d [ S5eUc[ nU"UR5Ulg)aInitialize the OtelSpanProcessor. Args: api_key: LangSmith API key. Defaults to LANGSMITH_API_KEY env var. project: Project identifier. Defaults to LANGSMITH_PROJECT env var. url: Base URL for LangSmith API. Defaults to LANGSMITH_ENDPOINT env var or https://api.smith.langchain.com. headers: Additional headers to include in requests. SpanProcessor: Optional span processor class. Defaults to BatchSpanProcessor. Nr5z/otel/v1/traces)r0r1r2r3r)rstripr. _exporterOTEL_AVAILABLErr _processor)rr1r2r0r3rK exporter_urls rrOtelSpanProcessor.__init__sh* !jjo.o>L%w  ~.   .M'7rc:URRX5 g)z1Forward span start events to the inner processor.N)rPon_start)rspanparent_contexts rrTOtelSpanProcessor.on_starts   6rc:URRU5 g)z/Forward span end events to the inner processor.N)rPon_end)rrUs rrYOtelSpanProcessor.on_ends t$rc8URR5 g)zShutdown processor.N)rPshutdownrs rr\OtelSpanProcessor.shutdowns   "rc8URRU5$)z Force flush the inner processor.)rP force_flush)rtimeout_milliss rr`OtelSpanProcessor.force_flushs**>::rcUR$)zThe underlying OtelExporter.)rNr]s rexporterOtelSpanProcessor.exporters~~rcUR$)zThe underlying span processor.)rPr]s r processorOtelSpanProcessor.processorsr)rNrP)NNNNN)N)i0u)rrrrr rrErFtyperrTrYr\r`propertyrdrgr!rrrrIrI|s<"&!%!,0(, (8#(8#(8c] (8 $sCx.) (8  ~ (8T7%#;rrI)r r>warningstypingr urllib.parser langsmithrr85opentelemetry.exporter.otlp.proto.http.trace_exporterropentelemetry.sdk.trace.exportrrOrwarn UserWarningr'r.rIrrrrss> '0VAN^<P#<P~__[+ MM &        NW+sA8A=<A=