qi "dZddlmZddlmZmZddlmZddlm Z ddl m Z ddl m Z ddlmZ dd lmZeGdde ZGdde Zy #e$r7Zej*d eej*d ed ed Z[wwxYw)zOpenPipe LLM service implementation for Pipecat. This module provides an OpenPipe-specific implementation of the OpenAI LLM service, enabling integration with OpenPipe's fine-tuning and monitoring capabilities. ) dataclass)DictOptional)logger)OpenAILLMInvocationParams)OpenAILLMSettings)OpenAILLMService)_warn_deprecated_param) AsyncOpenAIz Exception: zIIn order to use OpenPipe, you need to `pip install pipecat-ai[openpipe]`.zMissing module: NceZdZdZy)OpenPipeLLMSettingsz Settings for OpenPipeLLMService.N)__name__ __module__ __qualname____doc__O/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/services/openpipe/llm.pyr r s*rr ceZdZUdZeZeed<dddddddddeedeedeed eed ed ee eefd eeffd Z ddZ de de ffd ZxZS)OpenPipeLLMServicezOpenPipe-powered Large Language Model service. Extends OpenAI's LLM service to integrate with OpenPipe's fine-tuning and monitoring platform. Provides enhanced request logging and tagging capabilities for model training and evaluation. _settingsNzhttps://app.openpipe.ai/api/v1)modelapi_keybase_urlopenpipe_api_keyopenpipe_base_urltagssettingsrrrrrrrc td} |tdtd|| _|| j|t |d||||| d|||_y)aInitialize OpenPipe LLM service. Args: model: The model name to use. Defaults to "gpt-4.1". .. deprecated:: 0.0.105 Use ``settings=OpenAILLMSettings(model=...)`` instead. api_key: OpenAI API key for authentication. If None, reads from environment. base_url: Custom OpenAI API endpoint URL. Uses default if None. openpipe_api_key: OpenPipe API key for enhanced features. If None, reads from environment. openpipe_base_url: OpenPipe API endpoint URL. Defaults to "https://app.openpipe.ai/api/v1". tags: Optional dictionary of tags to apply to all requests for tracking. settings: Runtime-updatable settings. When provided alongside deprecated parameters, ``settings`` values take precedence. **kwargs: Additional arguments passed to parent OpenAILLMService. zgpt-4.1)rNr)rrrrrr)r r r apply_updatesuper__init___tags) selfrrrrrrrkwargsdefault_settings __class__s rr"zOpenPipeLLMService.__init__1sx</Y?   "7,? I%*  "    ) )( 3  -/%     rc ||jdxsd}|jdxsd}t||||d}|S)aJCreate an OpenPipe client instance. Args: api_key: OpenAI API key for authentication. base_url: OpenAI API base URL. **kwargs: Additional arguments including openpipe_api_key and openpipe_base_url. Returns: Configured OpenPipe AsyncOpenAI client instance. rr)rr)rropenpipe)get OpenPipeAI)r$rrr%rrclients r create_clientz OpenPipeLLMService.create_clientfsN"::&89?R"JJ':;Ar!1?PQ   rparams_from_contextreturncJt||}|jdd|d<|S)aBuild parameters for OpenPipe chat completion request. Adds OpenPipe-specific logging and tagging parameters. Args: params_from_context: Parameters, derived from the LLM context, to use for the chat completion. Contains messages, tools, and tool choice. Returns: Dictionary of parameters for the chat completion request. T)r log_requestr*)r!build_chat_completion_paramsr#)r$r/paramsr's rr3z/OpenPipeLLMService.build_chat_completion_paramszs456IJJJ z  r)NN)rrrrr Settings__annotations__rstrrr"r.rdictr3 __classcell__)r's@rrr&s#H"" $!%"&*.!A)-263}3# 3 3- 3 #3- 33tCH~&3./3j(@Y^brr)r dataclassesrtypingrrlogurur)pipecat.adapters.services.open_ai_adapterr pipecat.services.openai.base_llmrpipecat.services.openai.llmr pipecat.services.settingsr r*r r,ModuleNotFoundErroreerror Exceptionr rrrrrEs "!O>8<,2  +   j)j,FLL;qc"#FLL\] &qc* ++,sAB2B  B