hdZddlZddlZddlmZddlmZddlmZ  ddl m Z ddl m Z dZGdde ZGddZy#e$r8ej d ed Gd d Z GddZ GddZdZYRwxYw)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]) stacklevelceZdZdZdZy)rzMock otlp span exporter class.ctdzMock init method.r ImportErrorselfargskwargss c/var/www/html/eduruby.in/venv/lib/python3.12/site-packages/langsmith/integrations/otel/processor.py__init__zOTLPSpanExporter.__init__. N__name__ __module__ __qualname____doc__rrrrrs , rrceZdZdZdZy)rz Mock batch span processor class.ctdr rrs rrzBatchSpanProcessor.__init__&rrNrrrrrr#s . rrc eZdZdZedZy)tracezMock trace class.ctd)z Mock get tracer provider method.rrrrrget_tracer_providerztrace.get_tracer_provider1s. rN)rrrr staticmethodr#rrrr!r!.s    rr!Fc `eZdZdZ ddeedeedeedeeeefffd ZxZS) OtelExporteraA 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 tjd}|jds|dz }|xs t|d}|xstjd}|xstj }|xsi}|s t d|sd}tjdd|i|}|r||d<||_ t |,d ||d |y) 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)endpointr*r) ls_utils get_api_urlendswithr get_api_keyget_tracer_project ValueErrorlogginginfor)superr) rr'r(r)r*rbase_urlr.exporter_headers __class__s rrzOtelExporter.__init__Fs$''-  % OH='(,<=7X11$7:X88:-R:  G LL%     4; 0 1  O(4DOOr)NNNN) rrrrrstrdictr __classcell__)r:s@rr&r&=se"!%!%,0 3P c]3P#3P# 3P $sCx.) 3P3Prr&c eZdZdZ ddeedeedeedeeeefdeef dZdd Z d Z d Z dd Z e d Ze dZy)OtelSpanProcessoraA 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) Nr(r)r'r* SpanProcessorcd}|r|jdd}t|||||_ts t d|t }||j|_y)a Initialize 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. Nr,z/otel/v1/traces)r'r(r)r*r)rstripr& _exporterOTEL_AVAILABLErr _processor)rr(r)r'r*r@ exporter_urls rrzOtelSpanProcessor.__init__sj* !jjo.o>L%gw  .   .M'7rc<|jj||y)z1Forward span start events to the inner processor.N)rEon_start)rspanparent_contexts rrHzOtelSpanProcessor.on_starts   ~6rc:|jj|y)z/Forward span end events to the inner processor.N)rEon_end)rrIs rrLzOtelSpanProcessor.on_ends t$rc8|jjy)zShutdown processor.N)rEshutdownrs rrNzOtelSpanProcessor.shutdowns   "rc8|jj|S)z Force flush the inner processor.)rE force_flush)rtimeout_milliss rrQzOtelSpanProcessor.force_flushs**>::rc|jS)zThe underlying OtelExporter.)rCrOs rexporterzOtelSpanProcessor.exporters~~rc|jS)zThe underlying span processor.)rErOs r processorzOtelSpanProcessor.processorsr)NNNNN)N)i0u)rrrrrr;r<typerrHrLrNrQpropertyrTrVrrrr?r?|s<"&!%!,0(, (8#(8#(8c] (8 $sCx.) (8  ~ (8T7%#;rr?)rr5warningstypingr urllib.parser langsmithrr/5opentelemetry.exporter.otlp.proto.http.trace_exporterropentelemetry.sdk.trace.exportrrDrwarn UserWarningr!r&r?rrrras> '0VAN^<P#<P~__[+HMM &        NW+sA:A?>A?