dh,~SrSSKrSSKJrJrJrJr SSKrSSKrSSK J r SSK J r J r Jr SSKJrJr "SS\ 5rg) aUtil that can interact with Zapier NLA. Full docs here: https://nla.zapier.com/start/ Note: this wrapper currently only implemented the `api_key` auth method for testing and server-side production use cases (using the developer's connected accounts on Zapier.com) For use-cases where LangChain + Zapier NLA is powering a user-facing application, and LangChain needs access to the end-user's connected accounts on Zapier.com, you'll need to use oauth. Review the full docs above and reach out to nla@zapier.com for developer support. N)AnyDictListOptionalget_from_dict_or_env) BaseModel ConfigDictmodel_validator)RequestSessionc Z\rSrSr%Sr\\S'\\S'Sr\\S'\"SS9r S \ \\44S jr S \ 4S jr S \S \S\S \ \\44SjrS*S\S\\ S\S \ 4SjjrS\S \4SjrS*S\S\S\\ S\S \4 Sjjr\"SS9\S\ S \4Sj55rS \\ 4SjrS \\ 4SjrS+S\S\S\\ S \ 4SjjrS+S\S\S\\ S \ 4SjjrS+S\S\S\\ S \ 4S jjrS+S\S\S\\ S \ 4S!jjrS"\S\S \4S#jr S"\S\S \4S$jr!S"\S\S \4S%jr"S"\S\S \4S&jr#S \4S'jr$S \4S(jr%S)r&g),ZapierNLAWrapperaWrapper for Zapier NLA. Full docs here: https://nla.zapier.com/start/ This wrapper supports both API Key and OAuth Credential auth methods. API Key is the fastest way to get started using this wrapper. Call this wrapper with either `zapier_nla_api_key` or `zapier_nla_oauth_access_token` arguments, or set the `ZAPIER_NLA_API_KEY` environment variable. If both arguments are set, the Access Token will take precedence. For use-cases where LangChain + Zapier NLA is powering a user-facing application, and LangChain needs access to the end-user's connected accounts on Zapier.com, you'll need to use OAuth. Review the full docs above to learn how to create your own provider and generate credentials. zapier_nla_api_keyzapier_nla_oauth_access_tokenzhttps://nla.zapier.com/api/v1/zapier_nla_api_baseforbid)extrareturncSSS.nUR(a"URSSUR305 U$URSUR05 U$)zFormat headers for requests.zapplication/json)Acceptz Content-Type AuthorizationzBearer z X-API-Key)rupdater)selfheaderss \/var/www/html/shao/venv/lib/python3.13/site-packages/langchain_community/utilities/zapier.py_format_headers ZapierNLAWrapper._format_headers4sc).   - - NN GD,N,N+O"PQ   NNK)@)@A Bc[R"5nURRUR 55 U$N)requestsr rrr)rsessions r _get_sessionZapierNLAWrapper._get_sessionDs0""$t3356r methodurlkwargsc# [R"UR5S9IShvN nUR"X40UD6IShvN nUR 5 UR 5IShvN sSSS5IShvN sSSS5IShvN $NjNPN*NN !,IShvN (df  O=fSSS5IShvN g!,IShvN (df  g=f7f)zMake an async request.)rN)aiohttp ClientSessionrrequestraise_for_statusjson)rr'r(r)r$responses r _arequestZapierNLAWrapper._arequestIs((1E1E1GHHGv=f==))+%]]_,>==IHH=,>I===IHHHHHs'C$BC$C BC  $B-B.B1 C =B>C  C$BC$C BC C$B5 $B'% B5 1C 8 C$CC$ C!C  C!C$N instructionsparams preview_onlycvU(aUO0nURSU05 U(aURSS05 U$)zCreate a payload for an action.r3r5T)r)rr3r4r5datas r_create_action_payload'ZapierNLAWrapper._create_action_payloadPs> vR     KK. / r action_idc(URSUS3-$)zCreate a url for an action.exposed/z /execute/)r)rr:s r_create_action_url#ZapierNLAWrapper._create_action_urlas''HYKy*IIIr cZURX#U5n[SURU5US9$)NPOSTr/)r8r r=)rr:r3r4r5r7s r_create_action_request'ZapierNLAWrapper._create_action_requestes7**<N   # #I .  r before)modevaluescJSnSU;aSnOSUS'[USSU5nX1S'U$)z,Validate that api key exists in environment.NrrZAPIER_NLA_API_KEYr)clsrFzapier_nla_api_key_defaultrs rvalidate_environment%ZapierNLAWrapper.validate_environmentssN &*" +f 4)+ &68F2 32  &  (:#$ r cf# URSURS-5IShvN nUS$N 7f)aDReturns a list of all exposed (enabled) actions associated with current user (associated with the set api_key). Change your exposed actions here: https://nla.zapier.com/demo/start/ The return list can be empty if no actions exposed. Else will contain a list of action objects: [{ "id": str, "description": str, "params": Dict[str, str] }] `params` will always contain an `instructions` key, the only required param. All others optional and if provided will override any AI guesses (see "understanding the AI guessing flow" here: https://nla.zapier.com/api/v1/docs) GETr<Nresults)r1r)rr0s ralistZapierNLAWrapper.alists6&t/G/G*/TUU ""Vs #1/ 1cUR5nURURS-5nUR5 UR5S$![R aXnWR S:XaAUR(a[R "SU3US9e[R "SU3US9eUeSnAff=f)aWReturns a list of all exposed (enabled) actions associated with current user (associated with the set api_key). Change your exposed actions here: https://nla.zapier.com/demo/start/ The return list can be empty if no actions exposed. Else will contain a list of action objects: [{ "id": str, "description": str, "params": Dict[str, str] }] `params` will always contain an `instructions` key, the only required param. All others optional and if provided will override any AI guesses (see "understanding the AI guessing flow" here: https://nla.zapier.com/docs/using-the-api#ai-guessing) r<izrAn unauthorized response occurred. Check that your access token is correct and doesn't need to be refreshed. Err: )r0zLAn unauthorized response occurred. Check that your api key is correct. Err: NrP) r%getrr.r# HTTPError status_coderr/)rr$r0http_errs rlistZapierNLAWrapper.lists&##% {{4#;#;j#HIH  % % ' }}y))!! ##s*55",,++3*6"*  ((,,4:7% N s.AB?'AB::B?cUR5nURXU5nURURU55nUR 5 UR 5S$)OExecutes an action that is identified by action_id, must be exposed (enabled) by the current user (associated with the set api_key). Change your exposed actions here: https://nla.zapier.com/demo/start/ The return JSON is guaranteed to be less than ~500 words (350 tokens) making it safe to inject into the prompt of another LLM call. result)r%rBsendprepare_requestr.r/rr:r3r4r$r-r0s rrunZapierNLAWrapper.runsZ##%--ivN<< 7 7 @A!!#}}x((r c# URSURU5URX#5S9IShvN nUS$N 7f)r[r@rANr\r1r=r8rr:r3r4r0s rarunZapierNLAWrapper.arunsP   # #I .,,\B(   !!  s3A? Ac UR5nU(aUO0nURSS05 URXUS5nURUR U55nUR 5 UR 5S$)Same as run, but instead of actually executing the action, will instead return a preview of params that have been guessed by the AI in case you need to explicitly review before executing.r5T input_params)r%rrBr]r^r.r/r_s rpreviewZapierNLAWrapper.previewsv ##%!r ~t,---ivtT<< 7 7 @A!!#}}~..r c # URSURU5URX#SS9S9IShvN nUS$N 7f)rhr@T)r5rANr\rcrds rapreviewZapierNLAWrapper.apreviewsV    # #I .,,\PT,U(   !!  s2A> AargscRUR"U0UD6n[R"U5$)[Same as run, but returns a stringified version of the JSON for insertting back into an LLM.)r`r/dumpsrror)r7s r run_as_strZapierNLAWrapper.run_as_str s&xx((zz$r cn# UR"U0UD6IShvN n[R"U5$N7f)rqN)rer/rrrss r arun_as_strZapierNLAWrapper.arun_as_strs1YY///zz$0 535cRUR"U0UD6n[R"U5$)_Same as preview, but returns a stringified version of the JSON for insertting back into an LLM.)rjr/rrrss rpreview_as_strZapierNLAWrapper.preview_as_strs&||T,V,zz$r cn# UR"U0UD6IShvN n[R"U5$N7f)r{N)rmr/rrrss rapreview_as_str ZapierNLAWrapper.apreview_as_strs1]]D3F33zz$4rycNUR5n[R"U5$)\Same as list, but returns a stringified version of the JSON for insertting back into an LLM.)rXr/rrractionss r list_as_strZapierNLAWrapper.list_as_str!s))+zz'""r cj# UR5IShvN n[R"U5$N7f)rN)rQr/rrrs r alist_as_strZapierNLAWrapper.alist_as_str's) $zz'""%s 313)NFr")'__name__ __module__ __qualname____firstlineno____doc__str__annotations__rr model_configrrr r%rr1rboolr8r=r rBr classmethodrLrrQrXr`rerjrmrtrwr|rrr__static_attributes__rr rrrs$#&&??Lc3h g -c--s-tCQTH~-"&"    "JCJCJ"&"            (#$3$0#T$Z#,&*d4j&*RKO)),/)9A$) )$KO"",/"9A$" "&KO / /,/ /9A$ /  /KO " ",/ "9A$ "  "  s s  s c c  C 3 3  3 # # #S# #C#r r)rr/typingrrrrr+r#langchain_core.utilsrpydanticr r r r r rrr rrs5  ,,5;;%R#yR#r