{hpddlmZddlmZmZmZmZddlmZm Z ddl Z ddl m Z ddl mZddlZddlZee efZej$dZgdZe d dd Ze d dd Ze d dd Ze d dd Z d dd Zy)) annotations)AnyUnionLiteraloverload)AsyncInstructor InstructorN)KnownModelName) BaseCachezinstructor.auto_client)openai azure_openai anthropicgoogle generative-aivertexaimistralcohere perplexitygroqwriterbedrockcerebrasdeepseek fireworksollamaxaic yNmodel async_clientcachekwargss W/var/www/html/hubwallet-dev/venv/lib/python3.12/site-packages/instructor/auto_client.py from_providerr&& c yrrr s r%r&r&/ r(c yrrr s r%r&r&8r'r(c yrrr s r%r&r&Ar*r(c  8|||d< |jdd\}8|dd }tj d |8| tj d ||| d}d |vr5|jd }|r"tj d|t|| |dk(rx ddl } ddl m } |r| j|n| j|} | | f8|r|ntjjd|} tj di|ddi | S|dk(r ddl}ddl m}m}ddl m } |xs|j,j/d}|jd|j,j/d}|jd d!}|sddlm}|d"|sddlm}|d#|r ||||$n ||||$} | | f8|r|ntjjd|} tj di|ddi | S|d&k(r ddl}dd'l m}|r|j5|n|j7|} |jd(d)}|| f8|r|ntjj8|d*|} tj di|ddi | S|d,k(r ddlm}dd-l m}ddl}|jd.d/}|xs|j,j/d0}i}d1D]}||vs|j|||<|j@d||d2|} |r || fd8d3|} n || fd48i|} tj di|ddi | S|d6k(r dd7l!m"}dd8l m#}ddl}|xs|j,j/d9}|r ||} n td:|r || f8dd;|} n || fd48i|} tj di|ddi | S|d=k(rY ddl$}dd>l m%}|r|jM|n|jA|} || fi|} tj di|ddi | S|d@k(r ddl } ddAl m'}ddl}|xs|j,j/dB}|s tdC|r| j|dDEn| j|dDE} || fd48i|} tj di|ddi | S|dGk(r[ ddl(} ddHl m)}!|r| jU|n| jW|} |!| fd48i|} tj di|ddi | S|dJk(rM ddKl,m-}"m.}#ddLl m/}$|r |"|n|#|} |$| fd48i|} tj di|ddi | S|dNk(r ddl}ddl0}%ddOl m1}&dP|vr|jdP}'n1tj dQ|j,j/dRdS}'i}(dTD]}||vr|j||(|<|je|j,vs9tj dU|jedV|j,|je|(|<|'|(dW<|%jfdi|(} |\8r?d&8jivsdX8jivrtjjj})ntjjl})n|})|&| f|)||dY|} tj di|ddi | S|d[k(rM dd\l7m8}*m9}+dd]l m:},|r |*|n|+|} |,| fd48i|} tj di|ddi | S|d_k(rM dd`l;m<}-m=}.ddal m>}/|r |-|n|.|} |/| fd48i|} tj di|ddi | S|d.k(rtjdctdde ddlm}dd-l m}ddl}|jdf|j,j/dg}0|jdh|j,j/didj}1|0s tdk|j@dd|0|1dl|} 8|d4<|r || fdmdi|} n || fi|} tj di|ddi | S|dok(rtjdptdde ddqlBm}dd-l m}ddl}|xs|j,j/d0}|jAd/|2} |r || fd8d3|} n || fd48i|} tj di|ddi | S|dsk(r ddl } ddl m } |jdtdu}2|jd ds}|r| j|2|vn| j|2|v} hdw}3t8fdx|3D}4|4rtjjntjj})| | f8|r|n|)d|} tj di|ddi | S|dzk(r ddl } ddl m } ddl}|xs|j,j/d{}|sddlm}|d||jdtd}}2|r| j||2En| j||2E} | | f8|r|ntjjd|} tj di|ddi | S|dk(rn ddlEm }5ddlFm }6ddl mG}7|r |6|n|5|} |7| f|r|ntjj8d|} tj di|ddi | Sddlm}tj%d|i|ddi |d|dt#t$rddlm}|ddwxYw#t $rddlm}|ddt"$r&} tj%d|| di|ddid} ~ wwxYw#t $rddlm}|d%dt"$r&} tj%d|| di|ddid} ~ wwxYw#t $rddlm}|d+dt"$r&} tj%d|| di|ddid} ~ wwxYw#t $rddlm}|d5dt"$r&} tj%d|| di|ddid} ~ wwxYw#t $rddlm}|d<dt"$r&} tj%d|| di|ddid} ~ wwxYw#t $rddlm}|d?dt"$r&} tj%d|| di|ddid} ~ wwxYw#t $rddlm}|dFdt"$r&} tj%d|| di|ddid} ~ wwxYw#t $rddlm}|dIdt"$r&} tj%d|| di|ddid} ~ wwxYw#t $rddlm}|dMdt"$r&} tj%d|| di|ddid} ~ wwxYw#t $rddlm}|dZdt"$r&} tj%d|| di|ddid} ~ wwxYw#t $rddlm}|d^dt"$r&} tj%d|| di|ddid} ~ wwxYw#t $rddlm}|dbdt"$r&} tj%d|| di|ddid} ~ wwxYw#t $rddlm}|dndt"$r&} tj%d|| di|ddid} ~ wwxYw#t $rddlm}|drdt"$r&} tj%d|| di|ddid} ~ wwxYw#t $rddlm}|dydt"$r&} tj%d|| di|ddid} ~ wwxYw#t $rddlm}|d~dt"$r&} tj%d|| di|ddid} ~ wwxYw#t $rddlm}|ddt"$r&} tj%d|| di|ddid} ~ wwxYw)aCreate an Instructor client from a model string. Args: model: String in format "provider/model-name" (e.g., "openai/gpt-4", "anthropic/claude-3-sonnet", "google/gemini-pro") async_client: Whether to return an async client cache: Optional cache adapter (e.g., ``AutoCache`` or ``RedisCache``) to enable transparent response caching. Automatically flows through **kwargs to all provider implementations. mode: Override the default mode for the provider. If not specified, uses the recommended default mode for each provider. **kwargs: Additional arguments passed to the provider client functions. This includes the cache parameter and any provider-specific options. Returns: Instructor or AsyncInstructor instance Raises: ValueError: If provider is not supported or model string is invalid ImportError: If required package for provider is not installed Examples: >>> import instructor >>> from instructor.cache import AutoCache >>> >>> # Basic usage >>> client = instructor.from_provider("openai/gpt-4") >>> client = instructor.from_provider("anthropic/claude-3-sonnet") >>> >>> # With caching >>> cache = AutoCache(maxsize=1000) >>> client = instructor.from_provider("openai/gpt-4", cache=cache) >>> >>> # Async clients >>> async_client = instructor.from_provider("openai/gpt-4", async_client=True) Nr#/r)ConfigurationErrorziModel string must be in format "provider/model-name" (e.g. "openai/gpt-4" or "anthropic/claude-3-sonnet") initialize)provider operationz&Initializing %s provider with model %s)extraz0Provider configuration: async_client=%s, mode=%sapi_keyz8API key provided for %s provider (length: %d characters)r ) from_openai)r5)r!modezClient initializedstatussuccessz`The openai package is required to use the OpenAI provider. Install it with `pip install openai`.z Error initializing %s client: %sTerror)exc_infor4r ) AzureOpenAIAsyncAzureOpenAIAZURE_OPENAI_API_KEYazure_endpointAZURE_OPENAI_ENDPOINT api_versionz 2024-02-01zAZURE_OPENAI_API_KEY is not set. Set it with `export AZURE_OPENAI_API_KEY=` or pass it as kwarg api_key=zAZURE_OPENAI_ENDPOINT is not set. Set it with `export AZURE_OPENAI_ENDPOINT=` or pass it as kwarg azure_endpoint=)r5rAr?zfThe openai package is required to use the Azure OpenAI provider. Install it with `pip install openai`.r)from_anthropic max_tokensi)r!r7rCziThe anthropic package is required to use the Anthropic provider. Install it with `pip install anthropic`.r) from_genairFGOOGLE_API_KEY) debug_config http_options credentialsprojectlocation)rr5) use_asyncr!r!zlThe google-genai package is required to use the Google provider. Install it with `pip install google-genai`.r)Mistral) from_mistralMISTRAL_API_KEYzPMISTRAL_API_KEY is not set. Set it with `export MISTRAL_API_KEY=`.)r!rKzgThe mistralai package is required to use the Mistral provider. Install it with `pip install mistralai`.r) from_coherez`The cohere package is required to use the Cohere provider. Install it with `pip install cohere`.r)from_perplexityPERPLEXITY_API_KEYzPERPLEXITY_API_KEY is not set. Set it with `export PERPLEXITY_API_KEY=` or pass it as a kwarg api_key=zhttps://api.perplexity.ai)r5base_urlzdThe openai package is required to use the Perplexity provider. Install it with `pip install openai`.r) from_groqzZThe groq package is required to use the Groq provider. Install it with `pip install groq`.r) AsyncWriterWriter) from_writerzfThe writerai package is required to use the Writer provider. Install it with `pip install writer-sdk`.r) from_bedrockregionz=AWS_DEFAULT_REGION is not set. Using default region us-east-1AWS_DEFAULT_REGIONz us-east-1)aws_access_key_idaws_secret_access_keyaws_session_tokenzUsing z from environment variable region_nameclaude)r7r"_asynczcThe boto3 package is required to use the AWS Bedrock provider. Install it with `pip install boto3`.r) AsyncCerebrasCerebras) from_cerebraszfThe cerebras package is required to use the Cerebras provider. Install it with `pip install cerebras`.r)AsyncFireworks Fireworks)from_fireworkszoThe fireworks-ai package is required to use the Fireworks provider. Install it with `pip install fireworks-ai`.zThe 'vertexai' provider is deprecated. Use 'google' provider with vertexai=True instead. Example: instructor.from_provider('google/gemini-pro', vertexai=True)) stacklevelrIGOOGLE_CLOUD_PROJECTrJGOOGLE_CLOUD_LOCATIONz us-central1zProject ID is required for Vertex AI. Set it with `export GOOGLE_CLOUD_PROJECT=` or pass it as kwarg project=)rrIrJrKznThe google-genai package is required to use the VertexAI provider. Install it with `pip install google-genai`.rzThe 'generative-ai' provider is deprecated. Use 'google' provider instead. Example: instructor.from_provider('google/gemini-pro'))genaizrThe google-genai package is required to use the Google GenAI provider. Install it with `pip install google-genai`.rrRzhttp://localhost:11434/v1)rRr5> qwen2.5llama3.1llama3.2 mistral-nemo qwen2.5-codercommand-r-plusfirefunction-v2qwen3llama4devstralc3BK|]}|jvywr)lower).0 capable_model model_names r% z from_provider..2s'!!!1!1!33!sz`The openai package is required to use the Ollama provider. Install it with `pip install openai`.rDEEPSEEK_API_KEYz|DEEPSEEK_API_KEY is not set. Set it with `export DEEPSEEK_API_KEY=` or pass it as kwarg api_key=zhttps://api.deepseek.comzbThe openai package is required to use the DeepSeek provider. Install it with `pip install openai`.r)Client)from_xai)r7r!z_The xai-sdk package is required to use the xAI provider. Install it with `pip install xai-sdk`.z2Error initializing %s client: unsupported providerzUnsupported provider: z. Supported providers are: r)zbedrock-runtime)Isplit ValueErrorinstructor.exceptionsr0loggerinfodebugpoplenr instructorr6 AsyncOpenAIOpenAIModeTOOLS ImportError Exceptionr:osr<r=environgetrrBAsyncAnthropic AnthropicANTHROPIC_TOOLS google.genairjrDr| mistralairLrMrrO AsyncClientrPrrS AsyncGroqGroqwriterairTrUrVboto3rWupperclientrv BEDROCK_TOOLS BEDROCK_JSONcerebras.cloud.sdkr`rarbfireworks.clientrcrdrewarningswarnDeprecationWarningranyJSONxai_sdk.sync.clientxai_sdk.aio.clientr}supported_providers)9r!r"r#r7r$r2r0 provider_infor5r r6rresulterr<r=r?rArrBrCrjrD vertexai_flag client_kwargskeyrLrMrrOrPrrSrTrUrVrrWrX aws_kwargs default_moder`rarbrcrdrerIrJrRtool_capable_modelssupports_tools SyncClientrr}rys9 @r%r&r&Js X w${{32*"* EM KK0   LL:   GF**Y'  LLJG #  8#   . ""7"3]]7]3  ! !Tz'<'< F KK$<<)<  M$ ^ #C   < .G0F!GG#ZZ "**..1H"IN!**]LAKD(z "D(D !# +#1 !# +#1 ! !Tz'<'< F KK$<<)<  M$ [ %   1 (((9(((9   L$7J# !Tz'F'F%   F KK$<<)<  M$ X 4  ( - #JJz59MA0@!AGM 9&=)/CM#& 9"U\\& F #FWd*WPVW#FG*GG KK$<<)<  M$ Y )  ) / B0A!BG 1 K %",@F&fIJI&I KK$<<)<  M$ X    . ""7"3]]7]3  !262F KK$<<)<  M$ \ !*   2 E0D!EG z ""#.I#]]#.I# %VH:HHF KK$<<)<  M$ V    , w/YYwY/  vBZB6BF KK$<<)<  M$ X   4 . G,G,  !DzDVDF KK$<<)<  M$ Y I    /6!H- S( &=&,jjoJsOYY[BJJ.LL6#))+6P!QR&(jj&=JsO >)/J} %"U\\BzBF|:#3#3#55ZEUEUEW9W#-??#@#@L#-??#?#?L# !!)#   F KK$<<)<  M$ Z   B 0 g.g.  #6FFvFF KK$<<)<  M$ [   B 1 w/w/  $FG*GGF KK$<<)<  M$ Z   T   1  ( - jjBJJNN;Q,RSGzzBJJNN+BMRH D "U\\! F )F7O#FEdEfE#F5f5 KK$<<)<  M$ _ $  E   !  $ - A0@!AG\\5'\BF#FWd*WPVW#FG*GG KK$<<)<  M$ X @   .zz*.IJHjjH5G ""Hg"F]]Hg]F  # !!%8!N *8 %%Z__=Q=Q ! !T| F KK$<<)<  M$ Z 3   . C0B!CGD(v zz*.HIH ""7X"F]]7X]F  ! !Tz'<'< F KK$<<)<  M$ U $  @ @ + G,0  !Tz';';  F KK$<<)<  M& = @ 6]6Hg6  !$XJ/((;'< >  C <  C  j  @$8   LL2::':    ~  @$8   LL2::':    B  @$;   LL2::':    `  @$>   LL2::':    J  @$;   LL2::':    4  @$8   LL2::':    L  @$8   LL2::':    4  @$6   LL2::':    4  @$<   LL2::':    J  @$7   LL2::':    4  @$:   LL2::':    4  @$>   LL2::':    f  @$>   LL2::':    F  @$>   LL2::':    x  @$8   LL2::':    ^  @$8   LL2::':    @  @$9   LL2::':    sm"A6m>C,oB pA q$A#qA>r"As+1B t4Au=#A w6BxC+x:A y A z!:C{*!A:|3"C}<;B=?A,A@"m;> o!n??o p '!pp  q0!qq r9!rr" s(!s##s(+ t1 !t,,t14 u:!u55u:= w!v>>w x &!xx  y/!yy z8!zz! {'!{""{'* |0 !|++|03 }9!}44}9< !~== A@ %!A@@A@ @ AA@.!AAAAA)TN) r!r r" Literal[True]r#BaseCache | Noner$rreturnr)FN) r!r r"Literal[False]r#rr$rrr ) r!strr"rr#rr$rrr) r!rr"rr#rr$rrr )FNN) r!zUnion[str, KnownModelName]r"boolr#rr7zUnion[instructor.Mode, None]r$rrz"Union[Instructor, AsyncInstructor]) __future__rtypingrrrrinstructor.clientrr rinstructor.modelsr instructor.cacher rloggingInstructorType getLoggerrrr&rr(r%rs"009,&z?23   3 4* #'"       $)"        #'"       $)"       ")- u  %u  u   u   ' u   u  ( u  r(