A'h, 0ddlZddlZddlZddlZddlmZddlmZmZm Z ddl m Z ddlm Z m Z mZmZddlmZddlmZmZmZmZmZmZmZmZmZmZmZddlmZmZdd l m!Z!dd l"m#Z#dd l$m%Z%dd l&m'Z'dd l(m)Z)ddl*m+Z+ddl,m-Z-m.Z.m/Z/ddl0m1Z1ddl2m3Z3m4Z4ddl5m6Z6m7Z7ddl8m9Z9ddl:m;Z;mZ>m?Z?m@Z@mAZAddlBmCZCmDZDmEZEmFZFddlGmHZHddlImJZJmKZKmLZLmMZMmNZNddlOmPZPddlQmRZRmSZSmTZTmUZUmVZVmWZWddlXmYZYmZZZddl[m\Z\m]Z]m^Z^ddl_m`Z`ddlambZbmcZcmdZdmeZemfZfddlgmhZhmiZiddljmkZkdd llmmZmmnZnejepZqd!eereefd"dfd#Zsd$emd"etfd%ZuGd&d'eZvGd(d)eMZwGd*d+eLZxd,e etd!ered-eeyetefd"eeegeffd.Zzd!ered/eyetefd"eyeteffd0Z{d1ed"e e|eteffd2Z}d3ee|etd4feyetetffd"e e|eteeetffd5Z~d/ed"ee e|eteffd6Zd!ereyd"e|eyete)feyeteUfeyetefffd7Zed8etd9ed:ed;d"e)fd<Zed=d>d8etd9ed:ed=d"ee)eUffd?Zd=d>d8etd9ed:ed"ee)eUffd@ZdAered"ee)fdBZdAered"ee+fdCZd8etdAered"eeUfdDZdAerdEeydFeyd8etd"ere!f dGZdHZy)IN) defaultdict) AwaitableHashableSequence)partial)isclass isfunctionismethod signature) FunctionType) AnyCallableLiteral NamedTupleOptionalUnioncastget_args get_originget_type_hintsoverload)RunnableRunnableConfig) BaseModel)Self)LangGraphDeprecationWarning) BaseCache) BaseChannel)BinaryOperatorAggregate)DynamicBarrierValueDynamicBarrierValueAfterFinish WaitForNames)EphemeralValue) LastValueLastValueAfterFinish)NamedBarrierValueNamedBarrierValueAfterFinish) Checkpoint) EMPTY_SEQ INTERRUPTMISSINGNS_ENDNS_SEP TAG_HIDDENTASKS) ErrorCodeInvalidUpdateError ParentCommandcreate_error_message)Branch)ENDSTART CompiledGraphGraphSend)SchemaCoercionMapper)ChannelKeyPlaceholderChannelTypePlaceholderConfiguredManagedValueManagedValueSpecis_managed_valueis_writable_managed_value) ChannelRead PregelNode) ChannelWriteChannelWriteEntryChannelWriteTupleEntry) BaseStore)All CachePolicy CheckpointerCommand RetryPolicy)get_field_defaultget_update_as_tuples) create_model) RunnableLikecoerce_to_runnableschemareturnct|trytj|ryt j d|dy)NzInvalid state_schema: z. Expected a type or Annotated[type, reducer]. Please provide a valid schema to ensure correct updates. See: https://langchain-ai.github.io/langgraph/reference/graphs/#stategraph) isinstancetypetypingrwarningswarn)rQs \/home/kushmeetdev/Regenta/Chatbot/venv/lib/python3.12/site-packages/langgraph/graph/state.py_warn_invalid_state_schemarZ[s=&$ v MM )V Vnodect|tr|jSt|r!t |d|j j Stdt|)N__name__zUnsupported node type: ) rTrget_namecallablegetattr __class__r^ TypeErrorrU)r\s rY_get_node_namerdgsO$!}} $tZ)@)@AA1$t*>??r[ceZdZUeed<eeeefed<e eed<ee e e e fed<ee ed<eZee eedfeeeffed<dZeed <y ) StateNodeSpecrunnablemetadatainput retry_policy cache_policy.endsFdeferN)r^ __module__ __qualname__r__annotations__rdictstrr rUrrKrrHr)rltuplermboolr[rYrfrfps}tCH~&& 95h{.C!CDEE;''=FD(5sCx$sCx.89 :FE4r[rfceZdZUdZeeefed<eeefed<eee fed<ee e eee ee fffed< d2dddde e e d e e e d e e e d e e e d df fd Zed eeeeffdZd3dede e d dfdZeddddddddedede eee fd e e e de e eeefde ede e eeefeedffd efdZeddddddddededede eee fd e e e de e eeefde ede e eeefeedffd efdZ d4dddddddde eefde edede eee fd e e e de e eeefde ede e eeefeedffd efdZde eeefd ed effd! Z d2d"ed#e ede eeeffede e eeeffe!e e eeefffd$e e eeefeefd%e ed ef d&Z"dee eeeeffd efd'Z# d4ddddddd(d)e$d*e e%d+e e&d,e e e'eefd-e e e'eefd.ed/e ed d0fd1Z(xZ)S)5 StateGrapha1A graph whose nodes communicate by reading and writing to a shared state. The signature of each node is State -> Partial. Each state key can optionally be annotated with a reducer function that will be used to aggregate the values of that key received from multiple nodes. The signature of a reducer function is (Value, Value) -> Value. Args: state_schema: The schema class that defines the state. config_schema: The schema class that defines the configuration. Use this to expose configurable parameters in your API. Example: ```python from langchain_core.runnables import RunnableConfig from typing_extensions import Annotated, TypedDict from langgraph.checkpoint.memory import MemorySaver from langgraph.graph import StateGraph def reducer(a: list, b: int | None) -> list: if b is not None: return a + [b] return a class State(TypedDict): x: Annotated[list, reducer] class ConfigSchema(TypedDict): r: float graph = StateGraph(State, config_schema=ConfigSchema) def node(state: State, config: RunnableConfig) -> dict: r = config["configurable"].get("r", 1.0) x = state["x"][-1] next_value = x * r * (1 - x) return {"x": next_value} graph.add_node("A", node) graph.set_entry_point("A") graph.set_finish_point("A") compiled = graph.compile() print(compiled.config_specs) # [ConfigurableFieldSpec(id='r', annotation=, name=None, description=None, default=None, is_shared=False, dependencies=None)] step1 = compiled.invoke({"x": 0.5}, {"configurable": {"r": 3.0}}) # {'x': [0.5, 0.75]} ``` nodeschannelsmanagedschemasN)rioutput state_schema config_schemarir|rRct||.|| td|}tjdt dn||}||}i|_i|_i|_i|_ ||_ ||_ ||_ |j||j|d|j|d||_t|_y)Nz-Must provide state_schema or input and outputzInitializing StateGraph without state_schema is deprecated. Please pass in an explicit state_schema instead of just an input and output schema.) stacklevelF allow_managed)super__init__ ValueErrorrWrXrr{ryrz type_hintsrQrir| _add_schemar~set waiting_edges)selfr}r~rir|rbs rYrzStateGraph.__init__s   } !PQQ L MMf+  }$~%   ;="    & e4 u5*?Bur[c ~|j|jDchc]\}}|D]}||fc}}}zScc}}}wN)edgesr)rstartsendstarts rY _all_edgeszStateGraph._all_edgessPzz,0,>,>  (VSF CHUCL     s8 rrQc||jvr0t|t|\}}}|r2|s0dj|}t |dd}t d|d|di|||j|<||j |<|jD]U\}} ||jvr3|j|| k7s't| tr8t d|d| |j|<W|jD]D\}}||jvr"|j||k7s't d |d||j|<Fyy) Nz, r^z%Invalid managed channels detected in z: z<. Managed channels are not permitted in Input/Output schema.z Channel 'z&' already exists with a different typezManaged value ') r{rZ _get_channelsjoinrarritemsryrTr$rz) rrQrryrzrnames schema_namekeychannels rYrzStateGraph._add_schemasl  % &v .,9&,A )Hgz} '*%fj"=  ;K=5'RRR$;h#:'#:DLL &0DOOF # ( 0 1 W$--'}}S)W4%gy9 ","+C50V W#*1DMM#& 1!(  0 W$,,&||C(G3(-cU2XY)0DLL% 0/ &r[F)rmrhriretryrk destinationsr\rmrhrrkr.cy)zqAdd a new node to the state graph. Will take the name of the function/runnable as the node name. Nru)rr\rmrhrirrkrs rYadd_nodezStateGraph.add_nodes r[actioncy)z"Add a new node to the state graph.Nru) rr\rrmrhrirrkrs rYrzStateGraph.add_nodes r[c t|tsQ|}t|tr|j}n!t |d|j j }| td||jvrtd|d|jrtjdt|ts5|}ttt |dt |dd}| td|t||jvrtd|d |tk(s |t k(rtd|d t"t$fD]#} | tt|vstd| d t&} t)|s"t+|st+t |d dr0t-t |d xs t-|x} r |}t/t1t3j4tt6|j8j;} | j=| x} rt| t>r t-| r| }| j=d x}rytA|}|tBur+tE|}|D]}tA|}|tFus|}|}n|tFur3tE|x}r&tA|dtHurtE|dx}r|} ||} ||jQ|tStU|tt|d||xs |jV||| ||jtt|<|S#tJtLtNf$rYwxYw)aAdd a new node to the state graph. Args: node: The function or runnable this node will run. If a string is provided, it will be used as the node name, and action will be used as the function or runnable. action: The action associated with the node. (default: None) Will be used as the node function or runnable if `node` is a string (node name). metadata: The metadata associated with the node. (default: None) input: The input schema for the node. (default: the graph's input schema) retry: The policy for retrying the node. (default: None) If a sequence is provided, the first matching policy will be applied. cache_policy: The cache policy for the node. (default: None) destinations: Destinations that indicate where a node can route to. This is useful for edgeless graphs with nodes that return `Command` objects. If a dict is provided, the keys will be used as the target node names and the values will be used as the labels for the edges. If a tuple is provided, the values will be used as the target node names. NOTE: this is only used for graph rendering and doesn't have any effect on the graph execution. Raises: ValueError: If the key is already being used as a state key. Example: ```python from langgraph.graph import START, StateGraph def my_node(state, config): return {"x": state["x"] + 1} builder = StateGraph(dict) builder.add_node(my_node) # node name will be 'my_node' builder.add_edge(START, "my_node") graph = builder.compile() graph.invoke({"x": 1}) # {'x': 2} ``` Example: Customize the name: ```python builder = StateGraph(dict) builder.add_node("my_fair_node", my_node) builder.add_edge(START, "my_fair_node") graph = builder.compile() graph.invoke({"x": 1}) # {'x': 2} ``` Returns: Self: The instance of the state graph, allowing for method chaining. r^Nz6Node name must be provided if action is not a function'z&' is already being used as a state keyzjAdding a node to a graph that has already been compiled. This will not be reflected in the compiled graph.namezNode `z` already present.z` is reserved.z?' is a reserved character and is not allowed in the node names.__call__rRrFrtrace)rirjrkrlrm),rTrrrr_rarbr^rrycompiledloggerwarningr RuntimeErrorrxr5r6r-r,r)r r rnextiterinspectr r parameterskeysgetrUrrrrJr NameErrorrc StopIterationrrfrPrQ)rr\rrmrhrirrkr characterrlhintsfirst_parameter_name input_hintrtn rtn_originrtn_argsarg arg_originrargsvalss rYrzStateGraph.add_node sKx$$F&(+(vz63C3C3L3LM| L 4== q&LMN N == NN: $$FWVVWVZQU5VWXD| L >  4:: vdV+=>? ? 3;$%-vdV>:; ; &) IDdO+  {"ab  8A* 6"F#GFJ=>' (CD*!&)**=+/#-- $\6 :(j,(&+YY/C%DDzD%j$7N:>DJJ& #5eWG!DEE  F e :; ; c>gTZZ71''BC C i 0':; r[sourcepathpath_mapthenc|jrtjdt|dd}|jxsd}||j |vrt d|jd|dtj|||d|j ||<|j ||jx}r|j||S) aAdd a conditional edge from the starting node to any number of destination nodes. Args: source: The starting node. This conditional edge will run when exiting this node. path: The callable that determines the next node or nodes. If not specifying `path_map` it should return one or more nodes. If it returns END, the graph will stop execution. path_map: Optional mapping of paths to node names. If omitted the paths returned by `path` should be node names. then: The name of a node to execute after the nodes selected by `path`. Returns: Self: The instance of the graph, allowing for method chaining. Note: Without typehints on the `path` function's return value (e.g., `-> Literal["foo", "__end__"]:`) or a path_map, the graph visualization assumes the edge could transition to any node in the graph. rNTr conditionzBranch with name `z` already exists for node ``) rrrrPrbranchesrr4 from_path input_schemar)rrrrrrrQs rYadd_conditional_edgesz StateGraph.add_conditional_edgess> == NN:  "$T>yy'K 4==( ($TYYK/J6(RST '-&6&6tXtT&R fd#]]6*40== =6 =   V $ r[c2t|dkr tdd}|D]v}t|trt|dk(r|\}}n t |}||j vrtd|d|j ||||j|||}x|S)aAdd a sequence of nodes that will be executed in the provided order. Args: nodes: A sequence of RunnableLike objects (e.g. a LangChain Runnable or a callable) or (name, RunnableLike) tuples. If no names are provided, the name will be inferred from the node object (e.g. a runnable or a callable name). Each node will be executed in the order provided. Raises: ValueError: if the sequence is empty. ValueError: if the sequence contains duplicate node names. Returns: Self: The instance of the state graph, allowing for method chaining. z$Sequence requires at least one node.Nrz/Node names must be unique: node with the name 'z' already exists. If you need to use two different runnables/callables with the same name (for example, using `lambda`), please provide them as tuples (name, runnable/callable).)lenrrTrsrdrxrr)rrx previous_namer\rs rY add_sequencezStateGraph.add_sequences$ u:>CD D'+  !D$&3t9>! d%d+tzz! EdVLvv MM$ %( mT2 M! !$ r[)cachestoreinterrupt_beforeinterrupt_afterdebugr checkpointerrrrrrrCompiledStateGraphc |xsg}|xsg}|j|dk7r |dk7r|ng|zngt|j|jdk(rd|j|jvrdnD|j|jj D cgc]\}} t | s|c} }} t|j dk(rd|j vrdn8|j j D cgc]\}} t | r|c} }} tdid|did|jdt|j dkDr;t|jr&t|jtr |jnd d id i|j |jtt|jid td dd| d| d|d|d|ddd|d|d|d|xsd} | j!td |j"j D]\}} | j!|| |j$D]\}}| j'|||j(D]\}}| j'|||j*j D]0\}}|j D]\}}| j-|||2| jScc} }wcc} }w)aCompiles the state graph into a `CompiledStateGraph` object. The compiled graph implements the `Runnable` interface and can be invoked, streamed, batched, and run asynchronously. Args: checkpointer: A checkpoint saver object or flag. If provided, this Checkpointer serves as a fully versioned "short-term memory" for the graph, allowing it to be paused, resumed, and replayed from any point. If None, it may inherit the parent graph's checkpointer when used as a subgraph. If False, it will not use or inherit any checkpointer. interrupt_before: An optional list of node names to interrupt before. interrupt_after: An optional list of node names to interrupt after. debug: A flag indicating whether to enable debug mode. name: The name to use for the compiled graph. Returns: CompiledStateGraph: The compiled state graph. *) interruptr__root__builderschema_to_mapper config_type input_modelNrxryinput_channels stream_modeupdatesoutput_channelsstream_channelsrinterrupt_before_nodesinterrupt_after_nodes auto_validateFrrrr LangGraphru)validaterr{r|rr?ryrr~rri issubclassrrzr6r# attach_noderxr attach_edgerr attach_branch)rrrrrrrrrvalrrrr\rrrrbranchs rYcompilezStateGraph.compileAsE>,1r)/R #c)&6%<!"W  4<< ,-2dll4;;77  !% T[[ 9 ? ? AC', 4==!Q&:+F %)MM$7$7$9 SAQRUAV &   ** t}}%)DJJ'tzz95   --,,~djj1 "!# $"% &,' (,) *&+ ,$4- .#2/ 0 1 23 45 67 8$9 > UD)))+ ,IC  d + ,** -JE3   , - -- .KFC   - . $}}224 rUr rrrpropertyrrsrrtrrrOrKrrHrrlistrrrrrrrrIrrFrGr __classcell__rbs@rYrwrwzs^1f ]" ##3 #$$ #'' (( $s)T#u[:J-J'K"KLL MM-1-1#E &*&* #EtCy)#E S *#E S " #E c# #E #EJ Cc3h0  0t0$s)0t0B -1%)EI.2IM    4S>*  S "  k8K+@@AB {+ uT#s(^U38_%DEF     -1%)EI.2IM        4S>*  S "  k8K+@@AB  {+  uT#s(^U38_%DEF       $*.\ -1%)EI.2IM\C%&\&\  \ 4S>* \S "\k8K+@@AB\{+\uT#s(^U38_%DEF\ \|$%T#Y"7$#$$$\EI"11 S%$x. 899 : S)E(DN*B$CDD E S%$x. 899 : < 15hm!4d3i!?@A1sm1 1f(lE#|2C,DDEF( (X&*k#&*%)<@;?"k#"k# " k#  " k# #5d3i#89 k#"%T#Y"78k#k#smk# k#r[rwc 6eZdZUeed<eeeee egeffed<deeeee egeffdeddffd Z ddee dee fdZ ddee dee fd Zd ed eeddfd Zd eeeefdeddfdZdddededededdf dZdeddfdZxZS)rrrkwargsrRNc 2t|di|||_yNru)rrr)rrrrbs rYrzCompiledStateGraph.__init__s "6" 0r[configct|jj|jj|jj|j dS)NInputtypr{ryr) _get_schemarrir{ryr_rrs rYget_input_schemaz#CompiledStateGraph.get_input_schemasD ""LL((\\**w'   r[ct|jj|jj|jj|j dS)NOutputr)rrr|r{ryr_rs rYget_output_schemaz$CompiledStateGraph.get_output_schemasD ##LL((\\**x(   r[rr\c " |tk(rZ|jj|jjj Dcgc]\}}t |s|c}} nbt |jj|jjj Dcgc]\}}t|r|c}}z dtdttfdtttt tff fd t# dgk(rt$n t#t&|!|j(t+|j(ndf}|tk(r6t-t.gtgtgt1|g|j2|<y|h|r |jn|jj4}|jj|Dcic]}||}}t7|dk(xrd|v}||j8vr|j8|} njA|} |jBrtEtntGtd |j| <t-| g|r t |n|| t1|g|jH|jJ|jL|jN |j2|<ytPcc}}wcc}}wcc}w) NrirRc.|yt|tr*|jDcgc]\}}|vs ||fc}}St|trH|jtj k(ry|j Dcgc]\}}|vs ||fc}}St|ttfr|rtd|Dr}g}|D]t}t|trG|jtj k(r1|jfd|j DZ|j|xsdv|St|x}rt|r t|Std|tj }t#|cc}}wcc}}w)Nc3<K|]}t|tywrrTrJ.0is rY zGCompiledStateGraph.attach_node.._get_updates..s>1 1g.>c36K|]\}}|vs ||fywrru)rkv output_keyss rYrzGCompiledStateGraph.attach_node.._get_updates..s%''+q![HXQF's  ruzExpected dict, got )message error_code)rTrqrrJgraphPARENT_update_as_tuplesrrsanyextendrUrrMr3r0INVALID_GRAPH_NODE_RETURN_VALUEr1) rirrrrtmsg _get_updatesrs rYr z4CompiledStateGraph.attach_node.._get_updatesst}E4(+0;;=M41aA'>'@#q!ADTQF54-0>>>13>A!!W-77gnn4$'/0/B/B/D' |A'<"=>E{"!"q(9+E;??*1%9(HH)--=Ns F F  F Fr)mapper)r!static)tagstriggersrywritersrF)guard)r$ryr!r%rhrjrkbound))r6rr{rirr?rryrzr@rrqr rrrsrrrE _get_root_control_branchrl_control_staticrBr.rCrxrQrr _pick_mapperrCHANNEL_BRANCH_TOformatrmr%r#rhrjrkrgr) rrr\rr write_entriesr input_valuesis_single_inputr!branch_channelr rs @@rYrzCompiledStateGraph.attach_nodes %<!LL001C1CDJJLAq'*K t||445 LL006689Aq,Q/9K $ .tS)$ . huS#X/ 0$ .P #$/J<$?y\  #&# (='tyy1   W  %<( \%m45 DJJsO  )-4::4<<3F3FL*.,,*>*>|*LMQAqDMLM!,/14S|9SOt444..|<%& LL++L9 7=%%l3.55c:N::%S)#Cu5 MM. ) )()0?$|,\%m45!..!..mm DJJsO S 9FNs L+L L rrc t|trZ|tk7rP|j|jj t ttj|dfyy|tk7rddj|d|}|jj|jr'ttt||j|<n&t!tt||j|<|j|j"j ||D]>}|j|jj t t||f@yy)Nzjoin:+:)rTrrr5rxr%appendrCrDr,r-rrrmr'rryr&r$)rrr channel_namers rYrzCompiledStateGraph.attach_edge=s+ fc "cz 6"**11 *+<+C+CC+H$OQ CZ"388F#3"4AcU;L||!!#&,,.JV/ l+/@S[.Q l+ JJsO $ $ + +L 9  5!))00 "3L%"H!JK r[T) with_readerrrrr7c  d dttttfdtdttt tfffd }|rj xsQ|jjvr#|jjjn|jj}t|jj|}||jvr|j|}n3t|||jj|}||j|<t!t"j$|dgk(r|dn|d|} nd} |jj&j)j+|| j,r^j,t.k7rIj0rj0j3n3|jjD cgc]} | j,k7s| c} } d d d } |jjj,j4rt7t|j8| <nt;t|j8| <|jj,j<j)| | D]H} | t.k7s |j| j&j)t?t | | fJyyycc} w) Npacketsr"rRc x|Dcgc]J}|rn |tk7r.get_writes..os'&IJ*Q*=1 D&s(*) r5rTr9rDr,r-rr5r" frozenset)r9r"r?writesrrrs rY get_writesz4CompiledStateGraph.attach_branch..get_writesZs! "DS &a.&#X+<+C+CA+F  F  {{v{{c1 %!%$v6$%&NU& M1 sAB7rrT)selectfreshr!r;r4r<)F) rrrrr9rtrDrrrxrirQrr{rr+rrrAdo_readr%r5runrr5rlvaluesrmr!ryr r$rC)rrrrr7rBrQryr!readerr\rlr6rs ``` rYrz CompiledStateGraph.attach_branchWs|AF eCI./ 9=  e-t34 5 : ((DLL... ""5)//\\((  DLL0089H.....v6%h 8O8OPV8WX06%%f-@G##&.:,&>x{H AFF 5!!((J)GH ;;6;;#-;; ""$'+||'9'9QtTV[[=PdQ  %UG1TF&9L||!!&++.44.LS.Q l+.A#.F l+ JJv{{ # , , 3 3L A #:JJsO++22$&7 c&J%LM .;Rs K+3K+ checkpointct|d}|d}|d}|sy|ddk\ryt|D]}|jds|jdd }||jvr8d |}||vrt |||j |n|j |}|j |i|j tifD]4} || vs| j |} || vrt | | || |<0| | |<6||vr||vr|j |||<|||<t|D]}|jd s|jddk(s+|jdd }||jvrNd |}||vrt |||j |n|j |}|j |i|j tifD]4} || vs| j |} || vrt | | || |<0| | |<6||vr||vr|j |||<|||<t|jj|sgtt} |jjD]-\} } | tk7s| tk7s| | j!| /t|D]}|tk(r||jvs|j |}|j |t"}| |D]} d | }||vrt |||n|}|j | i|j tifD]4} || vs| j |} || vrt | | || |<0| | |<6||vr |t"ur|||<|||<t|vs|tj |t"yy) z+Migrate a checkpoint to new channel layout.channel_valueschannel_versions versions_seenNrzstart:r4rz branch:to:r;)r startswithsplitrxmaxpoprr*countr isdisjointrrrr6r5r5r+)rrIrGversionsseenrr\new_knew_vssssource_to_targetrrrcs rY_migrate_checkpointz&CompiledStateGraph._migrate_checkpoints,-01/*  c?a  h (A||H%wws|Atzz)$TF+(a9!a  88D"-txx 2/FG*BBwFF1I B;(+Ar%y(9BuI()BuI *&1;$*JJqMF5M"'3 (8h (A||I&1773<1+<wws|B'tzz)$TF+(a9!a  88D"-txx 2/FG*BBwFF1I B;(+Ar%y(9BuI()BuI *&1;$*JJqMF5M"'3 (64::))(3*40 "ll00 8 sE>cSj$U+2237 8(^ 8: ? QA 1g.A/20",SE 2;@H;LHUOQ 7RS#'88C#4dhhy"6M"N2B Bw$&FF1I#(B;03Ar%y0ABuI01BuI 2!.1G3C,-F5M*/!0$!D(Y++Aw73 8 4r[r)r^rnrorwrprqrUr rrrrrrrrrrfrrrrr4rtrr(r^rrs@rYrrsQ 49hxs /C&DDEE1tCy(8SE3J3G*HHI1 1  126 ~. i 26 ~. i ksk(=*AkdkZ%Xc](:";#$6MQMM #M-3MEIM M^f8jf8Tf8r[r state_keysrc|dgk(ryt|r.t|tryt|tr t ||St t |S)Nr)r)rrrqrr:r _coerce_state)r_rQrs rYr+r+sIj\!v fd # fi (':F F =& ))r[ric|di|Srru)rQris rYraras ?E?r[valuect|tr t|ffSg}t|tr|j |n?t|t t fr)|D]$}t|ts|j |&g}|D]}|jtjk(r t|t|jtr"|j t|jfgt|jtr1|j tj|jdf|jd|jD|S)Nc3zK|]3}t|trt|fntj |df5ywr)rTr9r/r,r-)rgos rYrz"_control_branch..3sBb$' '..r2D9:s9;)rTr9r/rJr5rrsrrr2gotorrr,r-r)rccommandscmdrcommands rYr)r) s%   H%! ED%= ) %C#w'$ %"$C  ==GNN *( ( gllD ) JJw||, -  c * JJ)00>E F JJ",,    Jr[rl.c"t|trD|jDcgc](\}}|tk(r|ntj |d|f*c}}S|Dcgc]%}|tk(r|ntj |ddf'c}Scc}}wcc}wr)rTrqrr5r,r-)rlrlabeles rYr*r*<s$!JJL 5s(Q 1 8 8 ;T5 I  SW MN!s(Q 1 8 8 ;T4 H    s -B*B ct|tr.|jtjk(ry|j St|t t fr|r~td|Drlg}|D]c}t|tr>|jtjk(r1|j|j Q|jd|fe|S|d|fgSy)Nruc3<K|]}t|tywrr r s rYrz_get_root..Rs61 1g&6rr) rTrJrrrrrsrrr5)rirrs rYr(r(Js%! ;;'.. (&&((54-(  66 6)+ 0A!W%77gnn,q2245 A/  0  U#$$ r[c t|dsdtd|diiifSt|d}|jDcic]\}}|dk7r |t||}}}|jDcic]\}}t |t s||c}}|jDcic]\}}t |s||c}}|fScc}}wcc}}wcc}}w)NrprFrT)include_extras __slots__)hasattr _get_channelrrrTrr?)rQrrrall_keysrrs rYrras 6, - j&N O     tq.AAB   JBsC2C  C &C:Cr annotationrFcyrrurrvrs rYrtrtxsr[Trcyrrurxs rYrtrt~s,/r[ct||x}r|r|Std|dt|x}r ||_|St |x}r ||_|St |}||_|S)NzThis z not allowed in this position)_is_field_managed_valuer_is_field_channelr_is_field_binopr$)rrvrmanagerrfallbacks rYrtrts*$ ;;w; NuZL0MNO O%j1 1 1 #J/ / / #J/HHL Or[rc,t|dr|j}t|dk\rt|dtr|dSt|dk\rHt |dr:t |dtr'|dt|dr|jS|Sy)N __metadata__rrO __origin__)rsrrrTrrrr)rmetas rYr|r|ssN# t9>jb;?8O Y!^R 1jb;6W48gc<.HCNNR RcR R r[c2t|dr|j}t|dk\rqt|drct |d}t |j j}td|Ddk(rt||dStd|y)NrrrOc3dK|](}|j|j|jfv*ywr)kindPOSITIONAL_ONLYPOSITIONAL_OR_KEYWORDr>s rYrz"_is_field_binop..s2FFq00!2I2IJJs.0rz5Invalid reducer signature. Expected (a, b) -> c. Got ) rsrrr`r rrrGsumrr)rrsigparamss rYr}r}ssN# t9>htBx0DH%C#..//12F#  /sDH== KC5Q r[cjt|dr|j}t|dk\rt|dxs|d}t |rmt |t r[|jjD]>\}}|tur||j|<|tus&|j|j|<@|Sy)NrrrO) rsrrrr?rTr=rrr;r<r)rrr decorationrrs rYr{r{ssN# t9>#DH-9bJ +j*@A * 1 1 7 7 9B1 5537J--a0 6636>>J--a0 B "! r[r{ryc t|rt|tr|St||j }t |dk(r'|ddk(rt |||djdfSt |||Dcic]C}||vr=t||tr*|||jt|||j|fEc}Scc}w)Nrrr)root)field_definitions) rrrrrrrN UpdateTyperTrrL)rr{ryrrrs rYrrs s| 3 2 GCL%%'( t9>d1g3tAw'22D9   %S\ #H}HQK)M  ..- ! ( 6 6 #   #  #sr?r@langgraph.pregel.readrArBlanggraph.pregel.writerCrDrElanggraph.store.baserFlanggraph.typesrGrHrIrJrKlanggraph.utils.fieldsrLrMlanggraph.utils.pydanticrNlanggraph.utils.runnablerOrP getLoggerr^rrUrZrrrdrfrwrrqr+rarsr)r*r(rrtrtr|r}r{rr,rur[rYrs #99<<    >"B*/< >I1 *>: +PPJ1E   8 $ uT#Y^'<  @@#@Jr#r#j]8]8@ *  *'+Cy *>FtCQTH~>V * hucz"# *$s)DcNtCH~38E#s(O#<8  c3hc3h/ 0   eChsm+,-  %S%XhuS#X&?@%. J 4[ !4-=(=#>S#X NO.  29%.   BF/ //29$-/ ;( ()/ / :> 26 ;( ()(49+)>cx0G'H*#DI(CS:T"          )_ F#r[