~tj&dZddlmZddlZddlmZmZddlmZddl m Z m Z ddl m Z ejeZgdZed dddd d ddZdS)z"LangSmith integration for Pipecat.) annotationsN)AnyOptional) warn_beta) set_thread_idthread_id_from_context)PipecatLangSmithSpanProcessor)r configure_pipecatrrllmpipecat) llm_span_kindapi_keyprojectendpoint service_namer strr Optional[str]rrrkwargsrreturn'Optional[PipecatLangSmithSpanProcessor]c  ddlm}ddlm}ddlm}n3#t $r&} td| Yd} ~ dSd} ~ wwxYw| |ddtd ||||d |} | } t| |r| | ntd | S) uEnable 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 rrrrrrrre processorproviders e/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/langsmith/integrations/pipecat/__init__.pyr r s/X'''''':::::://///// CQGGGttttt  \DQVWWW-#   I((**H(N++ ##I.... @    s AAA)r rrrrrrrrrrrrr)__doc__ __future__rloggingtypingrr#langsmith._internal._beta_decoratorrlangsmith._internal.voicerr(langsmith.integrations.pipecat.processorr getLogger__name__r"__all__r rr+r7s(("""""" 999999KKKKKKKKRRRRRR  8 $ $    !!"! GGGGG GGGr6