tj&vddlmZddlZddlZddlZddlZddlmZmZddl m Z ddl m Z ddl mZmZmZmZddlmZddlmZdd lmZdd lmZdd lmZmZdd lmZdd lm Z eefZ!d1dZ"d2dZ#d3dZ$d3dZ%d4dZ&d5d!Z'd6d"Z(d6d#Z)d7d&Z*d8d*Z+Gd+d,ej,Z-Gd-d.ej,Z.d9d0Z/dS):) annotationsN)CallableSequence)partial)Any)RunnableRunnableLambdaRunnableParallelRunnableSequence)RunnableBindingBase)run_in_executor)ChannelVersions)override)RunnableCallable RunnableSeq)sync_timeout_unsupported)PregelProtocolprevious_versionsrcurrent_versionsreturncrhttt|d}|fd|D}n|}|S)zEGet subset of current_versions that are newer than previous_versions.NcPi|]"\}}||k||#S)get).0kv null_versionrs U/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/langgraph/pregel/_utils.py z,get_new_channel_versions..$sE   1$((L9999 q999)typenextitervaluesitems)rr version_type new_versionsrs` @rget_new_channel_versionsr)s (D&6&=&=&?&?!@!@$GGHH #|~~      (..00   ( r! candidaterPregelProtocol | Nonecddlm}|g}|D]0}t|trt||r |jdur|cSt|t st|t r||jzt|tr||j t|trq|j 2|dt|j D|j1|dt|jD2dS)Nr)PregelFc3HK|]}t|dr|jn|VdS__self__Nhasattrr0rnls r z'find_subgraph_pregel..AK""$+2z#:#:BBKK""""""r!c3HK|]}t|dr|jn|VdSr/r1r3s rr5z'find_subgraph_pregel..Fr6r!)langgraph.pregelr- isinstancer checkpointerr rextendstepsr depsrfuncget_function_nonlocalsafunc)r*r- candidatescs rfind_subgraph_pregelrC/s~''''''"+J  q. ) )  6** /0nE.I.IHHH + , ,  1k0J0J    ag & & & & > * *    af % % % % + , , v!!!""4QV<<"""$!!""4QW==""" 4r!runnableSequence[Runnable] | Nonec>t|tr|jSdSN)r9_SEQUENCE_TYPESr<rDs r_sequence_stepsrJNs!(O,,~ 4r!c|t|tr&t|jSdSrG)r9r tuplesteps__r%rIs r_parallel_stepsrNTs7(,--0X%,,../// 4r! method_namestrboolcttt||d}|duo|tt|uSrG)getattrr"r)rDrOmethods r_has_method_overriderUZs8 T(^^[$ 7 7F   N&+0N0N"NNr!r@Callable[..., Any] | NonecHt|to |jtuSrG)r9rr>r )r@s r_is_executor_backed_afuncrX_s eW % % G%**GGr!ct|tr|jduot|j St|trt t |ddSt|dS)Nr@Fainvoke)r9rr@rXr rQrSrUrIs r_has_native_asyncr[cs~(,-- ~T) 2K N3 3 /  (N++7GHgu55666 ) 4 44r!ct|tr|j}t|tt|}|t |}|t d|DSt |S)uIReturn whether a runnable can be idle-timed without known sync code. For custom runnable subclasses, an `ainvoke` override is treated as the async contract. We do not introspect whether that implementation delegates to blocking work internally — e.g. a subclass whose `ainvoke` calls `asyncio.to_thread(self.invoke, ...)` will pass this check but the wrapped sync work is still uncancellable. Idle-timeout enforcement on such a runnable will fire `NodeTimeoutError` correctly, but the background thread will keep running until its sync work returns. Nc34K|]}t|VdSrG)_runnable_has_native_async)rsteps rr5z-_runnable_has_native_async..s+FF-d33FFFFFFr!)r9r boundrJrNallr[)rDr<s rr^r^ms X2 3 3"> X2 3 3" H % %E })) FFFFFFFF X & &&r!nameNonecBt|st|dSrG)r^r)rDrbs rvalidate_timeout_supportedres* %h / /-&t,,,--r!r>r list[Any]cD tj|}tjt j|}t }||g}t|dr-t|j rtj |j ntj |}i|j |j }|D]\}}||j vr|||j D]x} d| vrr| |r]|} | dddD](} | n8 t%| | } #t&$rYnwxYw|| yn%#t(t*t,t.f$rgcYSwxYw|S)zGet the nonlocal variables accessed by a function. Args: func: The function to check. Returns: List[Any]: The nonlocal variables accessed by the function. __wrapped__.N)inspect getsourceastparsetextwrapdedentFunctionNonLocalsvisitr2callablerhgetclosurevarsglobals nonlocalsr&append startswithsplitrSAttributeError SyntaxError TypeErrorOSError SystemError) r>codetreevisitorr%closurerArrkkvvparts rr?r?s &&y..//#%% dt]++ .089I0J0J .G "4#3 4 4 4'--  >=7+<= $$&& * *DAqG%%% a   ' * *"99q!1!19B " abb 1 * *:!E&%,R%6%6#1&&& %& b))) * * G[ 9  Ms6D>E;EE; E E;E E;;FFcbeZdZdZddZeddZedd Zedd Zd S)rqz2Get the nonlocal variables accessed of a function.rrcc,t|_dSrG)setrvselfs r__init__zFunctionNonLocals.__init__s#&55r!nodeast.FunctionDefrct}|||j|j|jz dS)zVisit a function definition. Args: node: The node to visit. Returns: Any: The result of the visit. N NonLocalsrrrvupdateloadsstoresrrrs rvisit_FunctionDefz#FunctionNonLocals.visit_FunctionDefD++ d gmgn<=====r!ast.AsyncFunctionDefct}|||j|j|jz dS)zVisit an async function definition. Args: node: The node to visit. Returns: Any: The result of the visit. Nrrs rvisit_AsyncFunctionDefz(FunctionNonLocals.visit_AsyncFunctionDefrr! ast.Lambdact}|||j|j|jz dS)zVisit a lambda function. Args: node: The node to visit. Returns: Any: The result of the visit. Nrrs r visit_LambdazFunctionNonLocals.visit_Lambdarr!Nrrc)rrrr)rrrr)rrrr) __name__ __module__ __qualname____doc__rrrrrrr!rrqrqs<<)))) > > >X > > > >X > > > >X > > >r!rqcJeZdZdZd dZed dZedd Zd S)rz Get nonlocal variables accessed.rrccRt|_t|_dSrG)rrrrs rrzNonLocals.__init__s"uu # r!rast.Namerct|jtjr!|j|jdSt|jtjr!|j|jdSdS)zVisit a name node. Args: node: The node to visit. Returns: Any: The result of the visit. N) r9ctxrmLoadraddidStorer)rrs r visit_NamezNonLocals.visit_Namesr dh ) ) % JNN47 # # # # # #) , , % KOODG $ $ $ $ $ % %r! ast.Attributect|jtjr|j}|j}t|tjr.|jdz|z}|j}t|tj.t|tjrF|j |j dz|z|j |j dSt|tj rt|j tjr&|j |j j dS|j }d}t|tjr8|r|jdz|z}n|j}|j}t|tj8t|tjr+|j |j dz|zdSdSdSdS)zVisit an attribute node. Args: node: The node to visit. Returns: Any: The result of the visit. riN)r9rrmrvalueattr AttributeNamerrrdiscardCallr>)rrparent attr_exprs rvisit_AttributezNonLocals.visit_Attributes dh ) ) DZF IVS]33 &"K#- 9 VS]33 &&#(++ D vy3:;;; ""69-----FCH-- Dfk3844 DJNN6;>22222#[F "I$VS];;.$4(. c(9I(EII(. I!' %VS];;. "&#(33D vy3'BCCCCC- D D D DDDr!Nr)rrrr)rrrr)rrrrrrrrrr!rrrst**&&&& % % %X %DDDXDDDr!rrcFttjd|S)zCCheck if the given string matches the format of xxh3_128_hexdigest.z [0-9a-f]{32})rQre fullmatch)rs ris_xxh3_128_hexdigestr!s  _e44 5 55r!)rrrrrr)r*rrr+)rDrrrE)rDrrOrPrrQ)r@rVrrQ)rDrrrQ)rDrrbrPrrc)r>rrrf)rrPrrQ)0 __future__rrmrkrrocollections.abcrr functoolsrtypingrlangchain_core.runnablesrr r r langchain_core.runnables.baser langchain_core.runnables.configr langgraph.checkpoint.basertyping_extensionsrlanggraph._internal._runnablerrlanggraph._internal._timeoutrlanggraph.pregel.protocolrrHr)rCrJrNrUrXr[r^rer? NodeVisitorrqrrrr!rrs""""""  ........ >=====;;;;;;555555&&&&&&GGGGGGGGAAAAAA444444 01$>  OOOO HHHH5555''''4---- ((((V.>.>.>.>.>.>.>.>b6D6D6D6D6D6D6D6Dr666666r!