ޠj&SrSSKJr SSKrSSKJrJr SSKJr SSK J r J r SSK J r \R"\5r/SQr\S SSSS S .S S jj5rg)z"LangSmith integration for Pipecat.) annotationsN)AnyOptional) warn_beta) set_thread_idthread_id_from_context)PipecatLangSmithSpanProcessor)r configure_pipecatrrllmpipecat) llm_span_kindapi_keyprojectendpoint service_namec XSSKJn SSKJn SSKJn URUSSS9 [S UUUUS .UD6n UR5n [X5(aU RU 5 U $[RS 5 U $![ a n [RSU 5 Sn A gSn A ff=f) ulEnable LangSmith tracing for a Pipecat pipeline. Installs Pipecat's OTel ``TracerProvider`` (via ``setup_tracing``) and registers a :class:`PipecatLangSmithSpanProcessor` that rewrites Pipecat's spans for LangSmith and exports them to LangSmith's OTLP endpoint. Enable tracing on the pipeline itself with ``PipelineTask(..., enable_tracing=True, enable_turn_tracking=True, params=PipelineParams(enable_metrics=True))``. To manage your own ``TracerProvider`` instead, skip this function and add ``PipecatLangSmithSpanProcessor(...)`` to your provider directly. To group a conversation's spans into a LangSmith thread, call :func:`set_thread_id` once per conversation (inside that conversation's asyncio task). The processor captures it as the conversation's spans start and applies it to every span in the trace — so it holds even for spans finished on a background task, and concurrent conversations stay separated. For a realtime (speech-to-speech) service, also call :meth:`PipecatLangSmithSpanProcessor.instrument_user_aggregator` on the returned processor. Pipecat delivers finalized user text through the user context aggregator rather than an OTel span. Args: llm_span_kind: LangSmith run kind for Pipecat's ``llm`` span; see the :mod:`~langsmith.integrations.pipecat.processor` module docstring. api_key / project / endpoint: LangSmith exporter config; default to the standard ``LANGSMITH_*`` resolution. service_name: OTel service name for the provider. Returns: The registered processor (so callers can e.g. ``attach_audio_buffer``), or ``None`` if Pipecat / OpenTelemetry aren't installed. r)trace)TracerProvider)setupz*Missing dependency for Pipecat tracing: %sNF)rexporterconsole_export)r rrrzjActive OTel TracerProvider is not an SDK TracerProvider; PipecatLangSmithSpanProcessor was not registered.) opentelemetryropentelemetry.sdk.tracerpipecat.utils.tracingr ImportErrorloggerwarning setup_tracingr get_tracer_provider isinstanceadd_span_processor) r rrrrkwargsrrre processorproviders a/var/www/html/gaurav/venv/lib/python3.13/site-packages/langsmith/integrations/pipecat/__init__.pyr r sX':/ \DQVW-#   I((*H(++##I.   @  / CQGsA?? B) B$$B))r strr Optional[str]rr)rr)rr(r#rreturnz'Optional[PipecatLangSmithSpanProcessor])__doc__ __future__rloggingtypingrr#langsmith._internal._beta_decoratorrlangsmith._internal.voicerr(langsmith.integrations.pipecat.processorr getLogger__name__r__all__r rr'r6s(" 9KR   8 $  !!"! GGG G  G  GG-G Gr5