g3fi=WdZddlmZddlZddlZddlZddlZddlZddlm Z m Z ddl m Z ddlm Z ddlmZddlmZmZmZmZmZmZdd lmZdd lmZerdd lmZmZmZmZmZm Z dd l!m"Z"dd l#m$Z$eddZ%eddZ&dDdZ'dEdZ(dFdZ)dFdZ*dFdZ+dGdZ,edZ-dd dHdZ.Gddej^Z0Gdd ej^Z1Gd!d"ej^Z2Gd#d$ej^Z3Gd%d&ej^Z4dId'Z5dJd(Z6e d)*dKd+Z7dLd,Z8Gd-d.e9e:efZ;ed/dZ<ed0dZ=Gd1d2ee=eed3e>eef4Z?dMd5Z@dNd6ZAGd7d8eZBGd9d:eZCGd;deZF dOd?ZGGd@dAZH dPdBZI dQdCZJy)RzUtility code for runnables.) annotationsN)MappingSequence) lru_cache) signature)groupby) TYPE_CHECKINGAny NamedTupleProtocol TypeGuardTypeVar)override) create_model) AsyncIterable AsyncIterator AwaitableCallable CoroutineIterable)Context) StreamEventInputT) contravariantOutput) covariantcK|4d{|d{cdddd{S777 #1d{7swYyxYww)zRun a coroutine with a semaphore. Args: semaphore: The semaphore to use. coro: The coroutine to run. Returns: The result of the coroutine. N) semaphorecoros \/var/www/auto_recruiter/arenv/lib/python3.12/site-packages/langchain_core/runnables/utils.py gated_coror"1sCzsDA)A/+/ A-A/AA8 AAcK|tj|d{Stj|tjfd|Dd{S7<7w)zGather coroutines with a limit on the number of concurrent coroutines. Args: n: The number of coroutines to run concurrently. *coros: The coroutines to run. Returns: The results of the coroutines. Nc36K|]}t|ywN)r").0crs r! z*gather_with_concurrency..Ns!Jq*Y":!Js)asynciogather Semaphore)ncorosrs @r!gather_with_concurrencyr.?sT y^^U+++!!!$I!JE!JK KK , Ls!AA7AAAAcn t|jjdduS#t$rYywxYw)zCheck if a callable accepts a run_manager argument. Args: callable: The callable to check. Returns: `True` if the callable accepts a run_manager argument, `False` otherwise. run_managerNFr parametersget ValueErrorcallables r!accepts_run_managerr7Qs:"--11-@LL  %( 44cn t|jjdduS#t$rYywxYw)zCheck if a callable accepts a config argument. Args: callable: The callable to check. Returns: `True` if the callable accepts a config argument, `False` otherwise. configNFr1r5s r!accepts_configr;`s:"--11(;4GG r8cn t|jjdduS#t$rYywxYw)zCheck if a callable accepts a context argument. Args: callable: The callable to check. Returns: `True` if the callable accepts a context argument, `False` otherwise. contextNFr1r5s r!accepts_contextr>os:"--11)rN)rRfuncrT AttributerVrWrXrMattrlenargsrZr[rNr\r]s r! visit_CallzIsLocalDict.visit_Calls tyy#-- 0499??CHH5 ""dii/ %'DII&(499Q<6499Q<--s3 IIMM$))A,,, -47)(06 1rDN)rMr[rNzset[str]returnNone)r^z ast.Subscriptrirj)r^zast.Callrirj)__name__ __module__ __qualname____doc__rPrr_rhrrDr!rKrKs2*,, ..rDrKcNeZdZdZddZeddZed dZed dZy) IsFunctionArgDictz4Check if the first argument of a function is a dict.c"t|_y)z#Create a IsFunctionArgDict visitor.N)setrNrOs r!rPzIsFunctionArgDict.__init__s !e rDc|jjsy|jjdj}t||jj |j y)UVisit a lambda function. Args: node: The node to visit. Nr)rgargrKrNvisitbodyrOr^input_arg_names r! visit_LambdazIsFunctionArgDict.visit_LambdasGyy~~ *..NDII.44TYY?rDc|jjsy|jjdj}t||jj |y)YVisit a function definition. Args: node: The node to visit. NrrgrvrKrNrwrys r!visit_FunctionDefz#IsFunctionArgDict.visit_FunctionDefCyy~~ *..NDII.44T:rDc|jjsy|jjdj}t||jj |y)`Visit an async function definition. Args: node: The node to visit. Nrr~rys r!visit_AsyncFunctionDefz(IsFunctionArgDict.visit_AsyncFunctionDefrrDNrirjr^z ast.Lambdarirjr^zast.FunctionDefrirjr^zast.AsyncFunctionDefrirj) rkrlrmrnrPrr{rrrrDr!rprpsH>$ @ @ ; ; ; ;rDrpc<eZdZdZddZeddZeddZy) NonLocalsz Get nonlocal variables accessed.c@t|_t|_y)zCreate a NonLocals visitor.N)rrloadsstoresrss r!rPzNonLocals.__init__s"u # rDc,t|jtjr&|jj |j yt|jtjr&|jj |j yy)zOVisit a name node. Args: node: The node to visit. N) rRrSrTrUrr\rXStorerr]s r! visit_NamezNonLocals.visit_NamesU dhh ) JJNN477 # #)) , KKOODGG $-rDcHt|jtjr|j}|j }t|tj r9|j dz|z}|j}t|tj r9t|tjrQ|jj|jdz|z|jj|jyt|tjr t|jtjr0|jj|jjy|j}d}t|tj rH|r|j dz|z}n |j }|j}t|tj rHt|tjr,|jj|jdz|zyyyy)zUVisit an attribute node. Args: node: The node to visit. .N)rRrSrTrUrVrerdrWrr\rXdiscardCallrc)rOr^parent attr_exprs r!visit_AttributezNonLocals.visit_Attributesm dhh )ZZF IVS]]3"KK#- 9 VS]]3&#((+ vyy3:; ""699-FCHH-fkk3884JJNN6;;>>2#[[F "I$VS]];$(. c(9I(EI(. I!' %VS]]; "&#((3 vyy3'BC4. *rDNr)r^zast.Namerirj)r^z ast.Attributerirj)rkrlrmrnrPrrrrrDr!rrs4*&  % %DDrDrcNeZdZdZddZeddZed dZed dZy) FunctionNonLocalsz2Get the nonlocal variables accessed of a function.c"t|_y)z#Create a FunctionNonLocals visitor.N)rr nonlocalsrss r!rPzFunctionNonLocals.__init__3s #&5rDct}|j||jj|j|j z y)r}NrrwrupdaterrrOr^visitors r!rz#FunctionNonLocals.visit_FunctionDef76+ d gmmgnn<=rDct}|j||jj|j|j z y)rNrrs r!rz(FunctionNonLocals.visit_AsyncFunctionDefBrrDct}|j||jj|j|j z y)ruNrrs r!r{zFunctionNonLocals.visit_LambdaMrrDNrrrr) rkrlrmrnrPrrrr{rrDr!rr0sF<)>>>>>>rDrc*eZdZdZddZeddZy)GetLambdaSourcez)Get the source code of a lambda function.c d|_d|_y)zInitialize the visitor.Nr)sourcecountrss r!rPzGetLambdaSource.__init__\s"&  rDc|xjdz c_ttdrtj||_yy)ruraunparseN)rhasattrrTrrr]s r!r{zGetLambdaSource.visit_Lambdaas0 a 3 "++d+DK #rDNrr)rkrlrmrnrPrr{rrDr!rrYs3 ,,rDrc8 tj|}tjt j |}t }|j||jrt|jSdS#ttttf$rYywxYw)zGet the keys of the first argument of a function if it is a dict. Args: func: The function to check. Returns: The keys of the first argument if it is a dict, None otherwise. N)inspect getsourcerTparsetextwrapdedentrprwrNsorted SyntaxError TypeErrorOSError SystemError)rccodetreers r! get_function_first_arg_dict_keysrmsw  &yy./#% d'.||vgll#== G[ 9sA8A=;A==BBc |jdk7r |jnd} tj|}t j t j|}t}|j||jdk(r |jS|S#t$rd}YwxYw#ttttf$r|cYSwxYw)zGet the source code of a lambda function. Args: func: a Callable that can be a lambda function. Returns: the source code of the lambda function. zNra)rkAttributeErrorrrrTrrrrrwrrrrrr)rcrMrrrs r!get_lambda_sourcers $  ;t}}  &yy./!# d%]]a/7>>9T9  G[ 9 s#BAB& B#"B#&CC)maxsizec6 tj|}tjt j |}t }|j|g}t|dr4t|jrtj|jntj|}i|j|j}|jD]\}}||jvr|j||jD]V} d| vs| j!|s|} | j#dddD]} | 7 t%| | } |j| X |S#t&$rYjwxYw#t(t*t,t.f$rgcYSwxYw)zGet the nonlocal variables accessed by a function. Args: func: The function to check. Returns: The nonlocal variables accessed by the function. __wrapped__rraN)rrrTrrrrrwrr6rgetclosurevarsglobalsritemsappend startswithsplitgetattrrrrrr) rcrrrvaluesclosure candidateskvkkvvparts r!get_function_nonlocalsrs  &yy./#% dt]+9I9I0J  " "4#3#3 4''-  >=7+<+<= $$& *DAqG%%% a '' *"9q!1B " ab 1*:!"!(T!2B * b) * *$ M ."!" G[ 9 sBDE:E:&E: E*E:* E7 3E:6E7 7E::FFct|}d|z}|j}dj|dg|ddDcgc]}||z c}zScc}w)zIndent all lines of text after the first line. Args: text: The text to indent. prefix: Used to determine the number of spaces to indent. Returns: The indented text.   rraN)rf splitlinesjoin)textprefixn_spacesspaceslineslines r!indent_lines_after_firstrsT6{H 8^F OO E 99eAhZU12Y"GT6D="GG HH"Gs A c eZdZdZddZddZy) AddableDictz3Dictionary that can be added to another dictionary.ct|}|D]+}||vs|| ||||<|| ||||z}|||<-|S#t$r||}YwxYw)zAdd a dictionary to this dictionary. Args: other: The other dictionary to add. Returns: A dictionary that is the result of adding the two dictionaries. rrrOotherchunkkeyaddeds r!__add__zAddableDict.__add__sD! #C%5:#5"3Zc s''!#Js3E#c  # !'!#JE' >AAct|}|D]+}||vs|| ||||<|| ||||z}|||<-|S#t$r||}YwxYw)zAdd this dictionary to another dictionary. Args: other: The other dictionary to be added to. Returns: A dictionary that is the result of adding the two dictionaries. rrs r!__radd__zAddableDict.__radd__sE" #C%5:#5!#Yc c&&!#Jc2E#c  # !& IE&rN)rrrir)rkrlrmrnrrrrDr!rrs=*rDr_T_co _T_contraceZdZdZddZy) SupportsAddz+Protocol for objects that support addition.cy)z!Add the object to another object.Nr)rOxs r!rzSupportsAdd.__add__srDN)rrrir)rkrlrmrnrrrDr!rrs 50rDrAddable)boundc*d}|D] }||n||z} |S)zAdd a sequence of addable objects together. Args: addables: The addable objects to add. Returns: The result of adding the addable objects. Nraddablesfinalrs r!r\r\s,!E:EEM: LrDcBKd}|23d{}||n||z}76|Sw)zAsynchronously add a sequence of addable objects together. Args: addables: The addable objects to add. Returns: The result of adding the addable objects. Nrrs r!aaddrs8!E::eEEM:x Ls cpeZdZUdZded< dZded< dZded< dZded < d Zd ed < e dd Z y)ConfigurableFieldz)Field that can be configured by the user.r[rXN str | NonerM descriptionz Any | None annotationFbool is_sharedcDt|j|jfSr%)hashrXrrss r!__hash__zConfigurableField.__hash__:sTWWdoo.//rDriint) rkrlrmrn__annotations__rMrrrrrrrDr!rr,sS3 G-D*!"K"(!J !'It& 00rDrcxeZdZUdZded< ded< ded< dZded < dZded < d Zd ed < eddZ y)ConfigurableFieldSingleOptionz>Field that can be configured by the user with a default value.r[rXMapping[str, Any]optionsdefaultNrrMrFrrct|jt|jj |j fSr%rrXtuplerrNr rss r!rz&ConfigurableFieldSingleOption.__hash__Os.TWWeDLL$5$5$78$,,GHHrDr rkrlrmrnrrMrrrrrrDr!rr?sYH G- $ L*D*!"K"(It& IIrDrcxeZdZUdZded< ded< ded< dZd ed < dZd ed < d Zd ed< eddZ y)ConfigurableFieldMultiOptionzFField that can be configured by the user with multiple default values.r[rXrrz Sequence[str]r NrrMrFrrct|jt|jj t|j fSr%r rss r!rz%ConfigurableFieldMultiOption.__hash__ds3TWWeDLL$5$5$78% :MNOOrDrr rrDr!rrTsZP G- $ +D*!"K"(It& PPrDrcxeZdZUdZded< ded< dZded< dZded < dZded < d Zd ed < dZ ded<y)ConfigurableFieldSpeczKField that can be configured by the user. It is a specification of a field.r[rXr rNrrMrr Frrlist[str] | None dependencies) rkrlrmrnrrMrr rrrrDr!rrnsWU G-O&D*!"K"(GS+It&%)L"))rDrctt|dd}g}|D]d\}}t|t|}t |dk(st fd|Dr|j Pd|dg|}t||S)zGet the unique config specs from a sequence of config specs. Args: specs: The config specs. Returns: The unique config specs. Raises: ValueError: If the runnable sequence contains conflicting config specs. c>|jg|jxsgSr%)rXrss r!z)get_unique_config_specs..sQTT$CQ^^-Ar$CrD)rc|jSr%)rXrs r!rz)get_unique_config_specs..s PQPTPTrDrc3(K|] }|k( ywr%r)r&ofirsts r!r(z*get_unique_config_specs..s">!1:">sz6RunnableSequence contains conflicting config specsfor z: )rrnextlistrfallrr4)specsgroupeduniquespec_iddupesothersmsgrs @r!get_unique_config_specsr(suCDnG+-F! "U e v;! s">v">> MM% ir5"26"2!35 S/ ! " MrDcFeZdZddddddd ddZddZy)_RootEventFilterN include_names include_types include_tags exclude_names exclude_types exclude_tagscX||_||_||_||_||_||_y)zUtility to filter the root event in the astream_events implementation. This is simply binding the arguments to the namespace to make save on a bit of typing in the astream_events implementation. Nr+)rOr,r-r.r/r0r1s r!rPz_RootEventFilter.__init__s4+*(**(rDcjjjd}nd}|jdxsg}j|xs|djv}j|xs|jv}j|xst fd|D}j |xr|dj v}j |xr|j v}j|xrtfd|D}|S)z&Determine whether to include an event.TFtagsrMc3:K|]}|jvywr%)r.r&tagrOs r!r(z1_RootEventFilter.include_event..s$T#SD,=,=%=$Tc3:K|]}|jvywr%)r1r6s r!r(z1_RootEventFilter.include_event..s!&144,,,&r8) r,r-r.r3anyr/r0r1r )rOevent root_typeinclude event_tagss` r! include_eventz_RootEventFilter.include_events$    &""*!!)GGYYv&,"    )Dv$2D2D!DG    )@d.@.@!@G    (T$T$T!TG    )I%-t7I7I"IG    )E)43E3E"EG    (#&8B&#GrD)r,Sequence[str] | Noner-r@r.r@r/r@r0r@r1r@rirj)r;rr<r[rir)rkrlrmrPr?rrDr!r*r*sf/3.2-1.2.2-1),), ) + ) , ),)+) ),rDr*ctj|xs-t|dxrtj|jS)zCheck if a function is an async generator. Args: func: The function to check. Returns: `True` if the function is an async generator, `False` otherwise. __call__)risasyncgenfunctionrrBrcs r!is_async_generatorrEs=  % %d + j! 6  & &t}} 5rDctj|xs-t|dxrtj|jS)zCheck if a function is async. Args: func: The function to check. Returns: `True` if the function is async, `False` otherwise. rB)r)iscoroutinefunctionrrBrDs r!is_async_callablerHs=  & &t , j! 7  ' ' 6rD)rzasyncio.Semaphorer rrir )r,z int | Noner-rrir)r6zCallable[..., Any]rir)rir)r Awaitable[_T]r=rrGrrirI)rcrrir)rcrrir)rcrriz list[Any])rr[rr[rir[)rzIterable[Addable]riAddable | None)rzAsyncIterable[Addable]rirJ)r!zIterable[ConfigurableFieldSpec]rizlist[ConfigurableFieldSpec])rcr riz'TypeGuard[Callable[..., AsyncIterator]])rcr riz#TypeGuard[Callable[..., Awaitable]])Krn __future__rrTr)rrBrcollections.abcrr functoolsrr itertoolsrtypingr r r r r rtyping_extensionsrlangchain_core.utils.pydanticrrrrrrr contextvarsrlangchain_core.runnables.schemarrrr"r.r7r;r>rErFrI NodeVisitorrKrprrrrrrrdictr[rrrrrr\rrrrAnyConfigurableFieldrr(r*rErHrrDr!rWs:!"  .'7$;t, T * L$   ' T]CH ");?(/.#///.d););X1D1Dh&>&>R,coo,(&:. 3''T I +$sCx.+\ 4( Kt 4 0(9e+,0 );sCx#8 9  0 0&IJI*P:P,558TT *J*& * @44n ," (rD