j dZddlZddlZddlmZmZddlmZddlm Z ddl m Z  ddl mZddlmZd ZGddeZGddZy#e$r8ej&d ed Gd dZGddZGddZdZYRwxYw)z8OpenTelemetry span processor and exporter for LangSmith.N)AnyOptional)urljoin)utils) set_langsmith_metadata_attribute)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 o/var/www/html/Fitness-lenito-AI-main/venv/lib/python3.12/site-packages/langsmith/integrations/otel/processor.py__init__zOTLPSpanExporter.__init__. N__name__ __module__ __qualname____doc__rrrrrs , rrceZdZdZdZy)r z Mock batch span processor class.ctdrrrs rrzBatchSpanProcessor.__init__'rrNrrrrr r $s . rr c eZdZdZedZy)tracezMock trace class.ctd)z Mock get tracer provider method.r rrrrget_tracer_providerztrace.get_tracer_provider2s. rN)rrrr staticmethodr%rrrr#r#/s    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. 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_urlr0exporter_headers __class__s rrzOtelExporter.__init__Hs&''-  % OH='(,<=7X11$7:X88:-R:  G LL%     4; 0 1  O(4DOOr)NNNN) rrrrrstrdictr __classcell__)r<s@rr(r(>se"!%!%,0 4P c]4P#4P# 4P $sCx.) 4P4Prr(c eZdZdZ ddeedeedeedeeeefdeef dZd eee fd dfd Z dd Z d Z dZ dZddZedZedZy)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|jdd}t|||||_ts t d|t }||j|_i|_y)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 _metadata)rr*r+r)r,rB exporter_urls rrzOtelSpanProcessor.__init__sq* !jjo.o>L%gw  .   .M'7)+rmetadatareturnc.|j|_y)a"Set metadata attributes to propagate to all spans. Use this to ensure metadata like ``thread_id`` appears on every span in a trace, not just the root span. This is required for LangSmith features (e.g. the threads view) that query runs by metadata fields. N)copyrH)rrJs r set_metadatazOtelSpanProcessor.set_metadatas"rc|jr/|jjD]\}}t||||jj ||y)z1Forward span start events to the inner processor.N)rHitemsrrGon_start)rspanparent_contextkeyvalues rrQzOtelSpanProcessor.on_startsD >>"nn224 U0sEB5   ~6rc:|jj|y)z/Forward span end events to the inner processor.N)rGon_endrrRs rrWzOtelSpanProcessor.on_ends t$rcht|jdr|jj|yy)z2Forward span ending events to the inner processor. _on_endingN)hasattrrGrZrXs rrZzOtelSpanProcessor._on_endings' 4??L 1 OO & &t , 2rc8|jjy)zShutdown processor.N)rGshutdownrs rr]zOtelSpanProcessor.shutdowns   "rc8|jj|S)z Force flush the inner processor.)rG force_flush)rtimeout_milliss rr`zOtelSpanProcessor.force_flushs**>::rc|jS)zThe underlying OtelExporter.)rEr^s rexporterzOtelSpanProcessor.exporters~~rc|jS)zThe underlying span processor.)rGr^s r processorzOtelSpanProcessor.processorsr)NNNNN)N)i0u)rrrrrr=r>typerrrNrQrWrZr]r`propertyrcrerrrrArAs>"&!%!,0(, ),#),#),c] ), $sCx.) ),  ~ ),V)T#s(^))7%- #;rrA)rr7warningstypingrr urllib.parser langsmithrr1"langsmith.integrations.otel._utilsr5opentelemetry.exporter.otlp.proto.http.trace_exporterropentelemetry.sdk.trace.exportr rFrwarn UserWarningr#r(rArrrrqs> 'O0VAN^>P#>PBrr_+HMM &        NW+sA :BB