U hy@sddlmZmZmZmZddlmZddlmZddl m Z ddl m Z ddl mZmZmZddlmZmZGdd d e Zd S) )AnyDictListOptional)CallbackManagerForRetrieverRun)Document) SecretStr) BaseRetriever)convert_to_secret_strget_from_dict_or_envpre_init) ArceeWrapper DALMFiltercseZdZUdZdZeeed<eed<e ed<dZ e ed<dZ e ed <d Z e ed <dZ eee efed <Gd ddZeddfdd ZeeedddZe eeeedddZZS)ArceeRetrieveraArcee Domain Adapted Language Models (DALMs) retriever. To use, set the ``ARCEE_API_KEY`` environment variable with your Arcee API key, or pass ``arcee_api_key`` as a named parameter. Example: .. code-block:: python from langchain_community.retrievers import ArceeRetriever retriever = ArceeRetriever( model="DALM-PubMed", arcee_api_key="ARCEE-API-KEY" ) documents = retriever.invoke("AI-driven music therapy") N_client arcee_api_keymodelzhttps://api.arcee.ai arcee_api_urlZv2arcee_api_versionzhttps://app.arcee.ai arcee_app_url model_kwargsc@seZdZdZdZdS)zArceeRetriever.ConfigZforbidTN)__name__ __module__ __qualname__extraZunderscore_attrs_are_privaterrH/tmp/pip-unpacked-wheel-9gdii04g/langchain_community/retrievers/arcee.pyConfig4sr)datareturnc s>tjf|t|j|j|j|j|jd|_ |j dS)zInitializes private fields.)rrrrZ model_nameN) super__init__r rZget_secret_valuerrrrrZvalidate_model_training_status)selfr __class__rrr!8szArceeRetriever.__init__)valuesrcCstt|dd|d<t|dd|d<t|dd|d<t|dd|d<|d r|d }|d d k rx|d d ksxtd |dd k rt|dtstd|dD]}tf|q|S)z%Validate Arcee environment variables.rZ ARCEE_API_KEYrZ ARCEE_API_URLrZ ARCEE_APP_URLrZARCEE_API_VERSIONrsizeNrz`size` must not be negative.filtersz`filters` must be a list.)r r get ValueError isinstancerr)clsr%kwfrrrvalidate_environmentsGsB z$ArceeRetriever.validate_environments)query run_managerkwargsrc Ks^z&|jstd|jjfd|i|WStk rX}ztd||W5d}~XYnXdS)aGRetrieve {size} contexts with your retriever for a given query Args: query: Query to submit to the model size: The max number of context results to retrieve. Defaults to 3. (Can be less if filters are provided). filters: Filters to apply to the context dataset. zClient is not initialized.r/z"Error while retrieving documents: N)rr)retrieve Exception)r"r/r0r1errr_get_relevant_documentsxs z&ArceeRetriever._get_relevant_documents)rrr__doc__rrr __annotations__rstrrrrrrrrr!r r.rrrr5 __classcell__rrr#rr s"    1rN)typingrrrrZlangchain_core.callbacksrZlangchain_core.documentsrZlangchain_core.pydantic_v1rZlangchain_core.retrieversr Zlangchain_core.utilsr r r Z#langchain_community.utilities.arceer rrrrrrs