§ î Ähãó"—dZddlZddlZddlmZddlmZddlmZ  ddl m Z ddl m Z dZnG#e$r?ejd ed ¬ ¦«Gd „d ¦«Z Gd„d¦«Z Gd„d¦«ZdZYnwxYwGd„de ¦«ZGd„d¦«ZdS)z8OpenTelemetry span processor and exporter for LangSmith.éN)ÚOptional)Úurljoin)Úutils)ÚOTLPSpanExporter)ÚBatchSpanProcessorTúwOpenTelemetry packages are not installed. Install optional OpenTelemetry dependencies with: pip install langsmith[otel]é)Ú stacklevelcó—eZdZdZd„ZdS)rzMock otlp span exporter class.có —td¦«‚©zMock init method.r©Ú ImportError©ÚselfÚargsÚkwargss úr/var/www/html/web-builder-api.evdpl.com/venv/lib/python3.11/site-packages/langsmith/integrations/otel/processor.pyÚ__init__zOTLPSpanExporter.__init__ó€åð.ñôð óN©Ú__name__Ú __module__Ú __qualname__Ú__doc__r©rrrrs)€€€€€Ø,Ð,ð ð ð ð ð rrcó—eZdZdZd„ZdS)rz Mock batch span processor class.có —td¦«‚r rrs rrzBatchSpanProcessor.__init__&rrNrrrrrr#s)€€€€€Ø.Ð.ð ð ð ð ð rrcó(—eZdZdZed„¦«ZdS)ÚtracezMock trace class.có —td¦«‚)z Mock get tracer provider method.rrrrrÚget_tracer_providerztrace.get_tracer_provider1s€õð.ñôð rN)rrrrÚ staticmethodr#rrrr!r!.s3€€€€€ØÐà ð ð ñ Œð ð ð rr!Fc ó~‡—eZdZdZ ddeedeedeedeeeeffˆfd„ ZˆxZS) Ú 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. NÚurlÚapi_keyÚprojectÚheadersc 󘕗tjd¦«}| d¦«s|dz }|pt|d¦«}|ptjd¦«}|ptj¦«}|pi}|st d¦«‚|sd}tjd¦«d|i|¥}|r||d<||_ t¦«j d ||d œ|¤ŽdS) aØInitialize 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_urlÚendswithrÚ get_api_keyÚget_tracer_projectÚ ValueErrorÚloggingÚinfor)Úsuperr) rr'r(r)r*rÚbase_urlr.Úexporter_headersÚ __class__s €rrzOtelExporter.__init__Fs ø€õ$Ô'¨Ñ-Ô-ˆà× Ò  Ñ%Ô%ð Ø ˜‰OˆHØÐ=' (Ð,<Ñ=Ô=ˆØÐ7XÔ1°$Ñ7Ô7ˆØÐ:XÔ8Ñ:Ô:ˆØ-˜Rˆàð Ýð:ñôð ð ð ؈GÝ ŒLð%ñ ô ð ð ˜ð àð Ðð ð <Ø4;Ð Ð0Ñ 1àˆŒ à‰ŒÔÐO (Ð4DÐOÐOÈÐOÐOÐOÐOÐOr)NNNN) rrrrrÚstrÚdictrÚ __classcell__)r:s@rr&r&=s¨ø€€€€€ððð"Ø!%Ø!%Ø,0ð 3Pð3Pà cŒ]ð3Pð˜#”ð3Pð˜#”ð 3Pð ˜$˜s C˜xœ.Ô)ð 3Pð3Pð3Pð3Pð3Pð3Pð3Pð3Pð3Pð3Prr&c óΗeZdZdZ ddeedeedeedeeeefdeef d„Zdd „Z d „Z d „Z dd „Z e d„¦«Ze d„¦«ZdS)Ú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*Ú SpanProcessorcóÖ—d}|r| d¦«›d}t||||¬¦«|_tst d¦«‚|€t }||j¦«|_dS)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&Ú _exporterÚOTEL_AVAILABLErrÚ _processor)rr(r)r'r*r@Ú exporter_urls rrzOtelSpanProcessor.__init__™s€ð*ˆ Ø ð ?Ø!Ÿjšj¨™oœoÐ>Ð>Ð>ˆLå%Ø g°wÈð ñ ô ˆŒõ ð Ýð.ñôð ð Ð Ý.ˆMà'˜-¨¬Ñ7Ô7ˆŒˆˆrcó<—|j ||¦«dS)z1Forward span start events to the inner processor.N)rEÚon_start)rÚspanÚparent_contexts rrHzOtelSpanProcessor.on_startÃs €à Œ× Ò   ~Ñ6Ô6Ð6Ð6Ð6rcó:—|j |¦«dS)z/Forward span end events to the inner processor.N)rEÚon_end)rrIs rrLzOtelSpanProcessor.on_endÇs€à Œ×Ò˜tÑ$Ô$Ð$Ð$Ð$rcó8—|j ¦«dS)zShutdown processor.N)rEÚshutdown©rs rrNzOtelSpanProcessor.shutdownËs€à Œ× Ò Ñ"Ô"Ð"Ð"Ð"ré0ucó6—|j |¦«S)z Force flush the inner processor.)rEÚ force_flush)rÚtimeout_milliss rrRzOtelSpanProcessor.force_flushÏs€àŒ×*Ò*¨>Ñ:Ô:Ð:rcó—|jS)zThe underlying OtelExporter.)rCrOs rÚexporterzOtelSpanProcessor.exporterÓs €ðŒ~Ðrcó—|jS)zThe underlying span processor.)rErOs rÚ processorzOtelSpanProcessor.processorØs €ðŒÐr)NNNNN)N)rP)rrrrrr;r<ÚtyperrHrLrNrRÚpropertyrUrWrrrr?r?|s€€€€€ððð<"&Ø!%Ø!Ø,0Ø(,ð (8ð(8à˜#”ð(8ð˜#”ð(8ðcŒ]ð (8ð ˜$˜s C˜xœ.Ô)ð (8ð   ”~ð (8ð(8ð(8ð(8ðT7ð7ð7ð7ð%ð%ð%ð#ð#ð#ð;ð;ð;ð;ðððñ„Xððððñ„Xðððrr?)rr5ÚwarningsÚtypingrÚ urllib.parserÚ langsmithrr/Ú5opentelemetry.exporter.otlp.proto.http.trace_exporterrÚopentelemetry.sdk.trace.exportrrDrÚwarnÚ UserWarningr!r&r?rrrúrbs»ðØ>Ð>à€€€Ø€€€ØÐÐÐÐÐØ Ð Ð Ð Ð Ð à'Ð'Ð'Ð'Ð'Ð'ð0ØVÐVÐVÐVÐVÐVØAÐAÐAÐAÐAÐAà€N€NøØð+ð+ð+Ø€H„Mð &ð Øð ñôðð ð ð ð ð ñ ô ð ð ð ð ð ð ñ ô ð ð ð ð ð ð ñ ô ð ð€N€N€NðW+øøøð\<Pð<Pð<Pð<Pð<PÐ#ñ<Pô<Pð<Pð~_ð_ð_ð_ð_ñ_ô_ð_ð_ð_sž-­AA1Á0A1