ޠj SrSSKrSSKrSSKJrJr SSKJr SSKJ r SSK J r SSK Jr SSKJr S r"SS\5r"SS5rg!\a5 \R&"S \S S 9 "S S5r"SS5r"SS5rSrNPf=f)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]) stacklevelc\rSrSrSrSrSrg)rzMock otlp span exporter class.c[S5ezMock init method.r  ImportErrorselfargskwargss _/var/www/html/gaurav/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__'rrrNrrrrr r $s . rr c(\rSrSrSr\S5rSrg)trace/zMock trace class.c[S5e)z Mock get tracer provider method.r rrrrget_tracer_providertrace.get_tracer_provider2s. rrN)rrr r!r" 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)endpointr5r) ls_utils get_api_urlendswithr get_api_keyget_tracer_project ValueErrorlogginginfor4superr) rr2r3r4r5rbase_urlr9exporter_headers __class__s rrOtelExporter.__init__Hs&''-  %% OH='(,<=7X11$7:X88:-R:  G LL%     4;0 1  O(OOr)r4)NNNN) rrr r!r"rstrdictrr# __classcell__)rEs@rr0r0>se"!%!%,0 4P c]4P#4P# 4P $sCx.) 4P4Prr0c \rSrSrSrSS\\S\\S\\S\\\\4S\\4 S jjr S \\\ 4S S4S jr SS jr Sr SrSrSSjr\S5r\S5rSrg)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) Nr3r4r2r5 SpanProcessorcSnU(aURS5S3n[XaX$S9Ul[(d [ S5eUc[ nU"UR5Ul0Ulg)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`. Nr7z/otel/v1/traces)r2r3r4r5r )rstripr0 _exporterOTEL_AVAILABLErr _processor _metadata)rr3r4r2r5rM exporter_urls rrOtelSpanProcessor.__init__so* !jjo.o>L%w  ~.   .M'7)+rmetadatareturnc.UR5Ulg)aSet 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)copyrS)rrVs r set_metadataOtelSpanProcessor.set_metadatas"rcUR(a/URR5Hup4[XU5 M URR X5 g)z1Forward span start events to the inner processor.N)rSitemsrrRon_start)rspanparent_contextkeyvalues rr^OtelSpanProcessor.on_starts> >>"nn224 0EB5   6rc:URRU5 g)z/Forward span end events to the inner processor.N)rRon_endrr_s rreOtelSpanProcessor.on_ends t$rcr[URS5(aURRU5 gg)z2Forward span ending events to the inner processor. _on_endingN)hasattrrRrirfs rriOtelSpanProcessor._on_endings* 4??L 1 1 OO & &t , 2rc8URR5 g)zShutdown processor.N)rRshutdownrs rrmOtelSpanProcessor.shutdowns   "rc8URRU5$)z Force flush the inner processor.)rR force_flush)rtimeout_milliss rrqOtelSpanProcessor.force_flushs**>::rcUR$)zThe underlying OtelExporter.)rPrns rexporterOtelSpanProcessor.exporters~~rcUR$)zThe underlying span processor.)rRrns r processorOtelSpanProcessor.processorsr)rPrSrR)NNNNN)N)i0u)rrr r!r"rrGrHtyperrrZr^rerirmrqpropertyrurxr#rrrrKrKs>"&!%!,0(, ),#),#),c] ), $sCx.) ),  ~ ),V)T#s(^))7%- #;rrK)r"r@warningstypingrr urllib.parser langsmithrr:"langsmith.integrations.otel._utilsr5opentelemetry.exporter.otlp.proto.http.trace_exporterropentelemetry.sdk.trace.exportr rQrwarn UserWarningr)r0rKrrrrs> 'O0VAN^>P#>PBrr_+ MM &        NW+sA 8BB