a i"dZddlZddlZddlmZddlmZddlmZ  ddl m Z ddl m Z dZnG#e$r?ejd ed Gd d Z GddZ GddZdZYnwxYwGdde ZGddZdS)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]) stacklevelceZdZdZdZdS)rzMock otlp span exporter class.c tdzMock init method.r ImportErrorselfargskwargss C:\Users\Dell Inspiron 16\Desktop\tws\AgrotaPowerBi\back-agrota-powerbi\mcp-client-agrota\venv\Lib\site-packages\langsmith/integrations/otel/processor.py__init__zOTLPSpanExporter.__init__. N__name__ __module__ __qualname____doc__rrrrrs),,     rrceZdZdZdZdS)rz Mock batch span processor class.c tdr rrs rrzBatchSpanProcessor.__init__&rrNrrrrrr#s)..     rrc(eZdZdZedZdS)tracezMock trace class.c td)z Mock get tracer provider method.rrrrrget_tracer_providerztrace.get_tracer_provider1s. rN)rrrr staticmethodr#rrrr!r!.s3       rr!Fc ~eZdZdZ ddeedeedeedeeeefffd ZxZS) OtelExportera&A 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. Nurlapi_keyprojectheadersc tjd}|ds|dz }|pt|d}|ptjd}|ptj}|pi}|st d|sd}tjdd|i|}|r||d<||_ tj d ||d |dS) 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__Gs &'--  %%  OH='(,<==7X1$77:X8::-R :   G L%        <4; 0 1 O(4DOOOOOOOr)NNNN) rrrrrstrdictr __classcell__)r:s@rr&r&=s"!%!%,0 4P4P c]4P#4P# 4P $sCx.) 4P4P4P4P4P4P4P4P4P4Prr&c eZdZdZ ddeedeedeedeeeefdeef dZdd Z d Z d Z d Z ddZ edZedZdS)OtelSpanProcessora&A 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|dd}t|||||_tst d|t }||j|_dS)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`. Nr,z/otel/v1/traces)r'r(r)r*r)rstripr& _exporterOTEL_AVAILABLErr _processor)rr(r)r'r*r@ exporter_urls rrzOtelSpanProcessor.__init__s*  ?!jjoo>>>L%gw     .   .M'-77rc<|j||dS)z1Forward span start events to the inner processor.N)rEon_start)rspanparent_contexts rrHzOtelSpanProcessor.on_starts    ~66666rc:|j|dS)z/Forward span end events to the inner processor.N)rEon_endrrIs rrLzOtelSpanProcessor.on_ends t$$$$$rcht|jdr|j|dSdS)z2Forward span ending events to the inner processor. _on_endingN)hasattrrErOrMs rrOzOtelSpanProcessor._on_endings< 4?L 1 1 - O & &t , , , , , - -rc8|jdS)zShutdown processor.N)rEshutdownrs rrRzOtelSpanProcessor.shutdowns   """""r0uc6|j|S)z Force flush the inner processor.)rE force_flush)rtimeout_milliss rrVzOtelSpanProcessor.force_flushs**>:::rc|jS)zThe underlying OtelExporter.)rCrSs rexporterzOtelSpanProcessor.exporters ~rc|jS)zThe underlying span processor.)rErSs r processorzOtelSpanProcessor.processors r)NNNNN)N)rT)rrrrrr;r<typerrHrLrOrRrVpropertyrYr[rrrr?r?~s!>"&!%!,0(, (8(8#(8#(8c] (8 $sCx.) (8  ~ (8(8(8(8T7777%%%--- ###;;;;XXrr?)rr5warningstypingr urllib.parser langsmithrr/5opentelemetry.exporter.otlp.proto.http.trace_exporterropentelemetry.sdk.trace.exportrrDrwarn UserWarningr!r&r?rrrrfs>> ''''''0VVVVVVAAAAAANN+++HM &                          NNNW+\>P>P>P>P>P#>P>P>PBeeeeeeeeees-AA10A1