o i @sdZddlmZddlmZmZddlmZddlm Z ddl m Z ddl m Z zddlmZWn eyPZzed eed ed ed Z[wweGd dde jZGddde Zd S)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)BaseOpenAILLMService)OpenAILLMService) AsyncOpenAIz Exception: zIIn order to use OpenPipe, you need to `pip install pipecat-ai[openpipe]`.zMissing module: Nc@seZdZdZdS)OpenPipeLLMSettingsz Settings for OpenPipeLLMService.N)__name__ __module__ __qualname____doc__rrQ/home/ubuntu/.local/lib/python3.10/site-packages/pipecat/services/openpipe/llm.pyr sr cseZdZUdZeZeed<dddddddddeedeedeed eed ed ee eefd eeffd dZ dddZ de de ffdd ZZS)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  s`|jdd} |dur|dd|| _|dur| |tjd||||| d|||_dS)aInitialize OpenPipe LLM service. Args: model: The model name to use. Defaults to "gpt-4.1". .. deprecated:: 0.0.105 Use ``settings=OpenPipeLLMService.Settings(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)Settings"_warn_init_param_moved_to_settingsr apply_updatesuper__init___tags) selfrrrrrrrkwargsdefault_settings __class__rrr0s    zOpenPipeLLMService.__init__cKs4|dpd}|dp d}t||||dd}|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!rrclientrrr create_clientes z OpenPipeLLMService.create_clientparams_from_contextreturncs t|}|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&)rbuild_chat_completion_paramsr)r r+paramsr#rrr.ys  z/OpenPipeLLMService.build_chat_completion_params)NN)r r r rr r__annotations__rstrrrr*rdictr. __classcell__rrr#rr%s8   5r)r dataclassesrtypingrrlogurur)pipecat.adapters.services.open_ai_adapterr pipecat.services.openai.base_llmrpipecat.services.openai.llmrr&r r(ModuleNotFoundErroreerror Exceptionrr rrrrrs$