Team Ai
Datasetpublic

codekingpro/portable-devtools

sourceHugging Faceupdated 5mo agoView on Hugging Face
1likes14kdownloads
_algo.cpython-313.pyc278 linesDownload Raw Back to __pycache__
1�

2��j���	�R�SSKJr SSKrSSKrSSKrSSKrSSKJrJr SSK	J3r4JrJrJ
r
 SSKJr SSKJr SSKJr SSKJrJrJrJrJrJr SS	KJr SS5KJrJr SSKJ r  SSK!J"r"J#r#J$r$J%r%J&r& SS
K'J(r( SSK)J*r* SSK+J,r,J-r- SSK.J/r/J0r0J1r1J2r2J3r3J4r4J5r5J6r6J7r7J8r8J9r9J:r:J;r;J<r<J=r=J>r>J?r?J@r@JArAJBrBJCrCJDrDJErEJFrFJGrGJHrHJIrIJJrJ SSKKJLrL SSKMJNrNJOrO SSKPJQrQ SSKRJSrS SSKTJUrU SSKVJWrW SSKXJYrY SSKZJ[r[ SSK\J]r]J^r^ SSK_J`r` SSKaJbrb SSKcJdrdJere SSKfJgrgJhrhJiri SSKjJkrkJlrlJmrmJnrnJoroJprpJqrqJrrr \6\&S-S/\&4rs\R�S:�ru"S S!\5rv"S"S#\5rw"S$S%5rxSFS&jrySGSHS'jjrzSIS(jr{SJS)jr|\SSSSSS*SS+.SKS,jj5r}\SSS*SS-.SLS.jj5r}SSSSSS*SS+.SMS/jjr}\F4r~"S0S1\5rSSSSSS*S2.SNS3jjr�SOS4jr�SPS5jr�SQS6jr�SRS7jr�SSSSS*S8.SSS9jjr�SSSSS*S8.STS:jjr�SSSSS*S8.SUS;jjr�SVS<jr�SWS=jr�SXS>jr�SYS?jr�SZS@jr�SZSAjr�S[SBjr�\GR"5r�"SCSD5r�S\SEjr�g)]�)�annotationsN)�defaultdict�deque)�Callable�Iterable�Mapping�Sequence)�copy)�partial)�sha1)�Any�Literal�7NamedTuple�Protocol�cast�overload)�	Callbacks)�AsyncParentRunManager�ParentRunManager)�RunnableConfig)�BaseCheckpointSaver�ChannelVersions�8Checkpoint�PendingWrite�V)�	BaseStore)�xxh3_128_hexdigest)�
merge_configs�patch_config)�CACHE_NS_WRITES�CONF�CONFIG_KEY_CHECKPOINT_ID�CONFIG_KEY_CHECKPOINT_MAP�CONFIG_KEY_CHECKPOINT_NS�CONFIG_KEY_CHECKPOINTER�CONFIG_KEY_NODE_ERROR�CONFIG_KEY_READ�CONFIG_KEY_RESUME_MAP�CONFIG_KEY_RUNTIME�CONFIG_KEY_SCRATCHPAD�CONFIG_KEY_SEND�CONFIG_KEY_TASK_ID�CONFIG_KEY_THREAD_ID�ERROR�ERROR_SOURCE_NODE�	INTERRUPT�	NO_WRITES�NS_END�NS_SEP�NULL_TASK_ID�PREVIOUS�PULL�PUSH�RESERVED�RESUME�RETURN�TASKS)�PregelScratchpad)�	EMPTY_SEQ�MISSING)�BaseChannel)�Topic)�UntrackedValue)�9TAG_HIDDEN)�	NodeError)�ManagedValueMapping)�get_runnable_for_task�10identifier)�
read_channels)�logger)�INPUT_CACHE_KEY_TYPE�11PregelNode)�DEFAULT_RUNTIME�
ExecutionInfo�Runtime)�All�CacheKey�CachePolicy�PregelExecutableTask�12PregelTask�RetryPolicy�Send�
TimeoutPolicy)��c�h�\rSrSrSr\S	Sj5r\S13Sj5r\SSj5r\SSj5r	Sr14g)
�WritesProtocol�]z}Protocol for objects containing writes to be applied to checkpoint.15Implemented by PregelTaskWrites and PregelExecutableTask.c��g�N���selfs �\D:\code\apps\devtools\python\user_packages\Python313\site-packages\langgraph/pregel/_algo.py�path�WritesProtocol.pathas��58�c��gr\r]r^s r`�name�WritesProtocol.nameds��rcc��gr\r]r^s r`�writes�WritesProtocol.writesgs��36rcc��gr\r]r^s r`�triggers�WritesProtocol.triggersjs��),rcr]N)�return�tuple[str | int | tuple, ...])rm�str)rm�Sequence[tuple[str, Any]])rm�
Sequence[str])�__name__�16__module__�__qualname__�__firstlineno__�__doc__�propertyrarerhrk�__static_attributes__r]rcr`rYrY]sB��A��8��8�
����
�6��6�
�,��,rcrYc�B�\rSrSr%SrS\S'S\S'S\S'S	\S17'Srg)
�PregelTaskWrites�nz�Simplest implementation of WritesProtocol, for usage with writes that18don't originate from a runnable task, eg. graph input, update_state, etc.rnrarorerprhrqrkr]N)rrrsrtrurv�__annotations__rxr]rcr`rzrzns!��Q�(�'�19
�I�%�%��rcrzc��\rSrSr%SrS\S'S\S'S\S'S	\S20'S\S'S
\S'SS.SSjjrSrg)�Call�x��func�input�retry_policy�cache_policy�	callbacks�timeoutrr��&tuple[tuple[Any, ...], dict[str, Any]]r��Sequence[RetryPolicy] | Noner��CachePolicy | Noner�rr��TimeoutPolicy | Noner�N�r�c�L�XlX lX0lX@lXPlX`lgr\r�)r_r�r�r�r�r�r�s       r`�__init__�
Call.__init__�s$���	��21�(��(��"���rc)r�r�r�r�r�r�)r�rr�r�r�r�r�r�r�rr�r�rm�None)rrrsrtru�	__slots__r|r�rxr]rcr`r~r~xs����I��N�1�1�.�.�$�$���
!�!�)-����6��223��)�
���&��23��rcr~c��^^�[[[USR55S55nU"5mUSR	[2405m[
UU4SjUSR555nU(agUVs/sHYnUS:Xa<UR(a*[URR	S[5;dMDOURU;dMWUPM[ sn$/$s snf)z@Check if the graph should be interrupted based on current state.�channel_versionsN�
versions_seenc3�R># �UHupUTRUT5:�v� M g7fr\)�get)�.0�chan�version�null_version�seens   ��r`�	<genexpr>�#should_interrupt.<locals>.<genexpr>�s*����+�C�M�D�	�$�(�(�4��.�.�C�s�$'�*�tags)�type�next�iter�valuesr�r0�any�items�configrBr=re)�25checkpoint�interrupt_nodes�tasks�version_type� any_updates_since_prev_interrupt�taskr�r�s      @@r`�should_interruptr��s������T�*�-?�"@�"G�"G�"I�J�D�Q�R�L��>�L��o�&�*�*�9�b�9�D�'*�+�'�(:�;�A�A�C�+�(�$�$,��	26���#�c�)����!��������)K�K�
���Y�Y�/�1�
��	27�����	28s�AC)�C)�C)c	��[[5n[U[5(a2/nURHup�X�:XdMXhRU	5 M! OaUV29s/sHo�U;dM30U31PM nn32UV33s/sHo�U;dM34U35PM nn36URHup�X�;dMXhRU	5 M! U(a@0nUH,n37XR
5nURXj5 X�U38'M. [X�5n
O[X5n
U(a3U
RUV39s0sHo�X*RU5_M sn405 U
$s sn41fs sn42fs sn43f)z�Function injected under CONFIG_KEY_READ in task config, to read current state.44Used by conditional edges to read a copy of the state with reflecting the writes45from that node only.)46r�list�47isinstancerorh�appendr48�updaterGr�)�49scratchpad�channels�managedr��select�fresh�updated�managed_keys�c�v�k�local_channels�ccr�s              r`�50local_readr��s,��%0��$5�G��&�#������K�K�D�A��{��51�!�!�!�$� �$*�:�6�a�'�\��6��:�#�8�V���'7�!�V��8��K�K�D�A��{��52�!�!�!�$� �
�13���A���!�!�#�B��I�I�g�j�!� "�1���53�~�6���x�0����
�
�l�K�l��'�*�.�.��4�4�l�K�L��M��%;��8�� Ls�	E�(E�4	E�E� Ec��UbUS-$S$)zHDefault channel versioning function, increments the current int version.�r])�current�channels  r`�	incrementr��s��!�-�7�Q�;�4�1�4rcc��[USS9n[SU55nUH\nUSRUR05R	UR54Vs0sHnXpS;dM
XpSU_M sn5 M^ UcSnO/U"US(a[
USR55OSS5nUVVs1sH,nUR55HnU[;dMXq;dMUiM M. snnH(nXR5(dMUcM!X�SU'M* [[5n	UH�nURH~upzU[[[[ ["[$[&4;aM0Xq;aX�R)U565 MJ[*R,"SURSUR.S	US5735 M� M� [15nU	R35H\up|Xq;dMXR	U5(dM&UcM+X�SU'XR55(dMKUR7U5 M^ U(a}UHwnXR55(dMX{;dM#XR	[85(dMAUcMFX�SU'XR55(dMfUR7U5 My U(anUR;U5(aXUHRnXR=5(dMUcM!X�SU'XR55(dMAUR7U5 MT U$s snfs snnf)a,Apply writes from a set of tasks (usually the tasks from a Pregel step)58to the checkpoint and channels, and return managed values writes to be applied59externally.60 61Args:62    checkpoint: The checkpoint to update.63    channels: The channels to update.64    tasks: The tasks to apply writes from.65    get_next_version: Optional function to determine the next version of a channel.66    trigger_to_nodes: Mapping of channel names to the set of nodes that can be triggered by updates to that channel.67 68Returns:69    Set of channels that were updated in this step.70c�2�[URSS5$)NrV)�
task_path_strra)�ts r`�<lambda>�apply_writes.<locals>.<lambda>s��
�a�f�f�R�a�j�(Arc)�keyc3�8# �UHoRv� M g7fr\)rk)r�r�s  r`r��apply_writes.<locals>.<genexpr>s���.��1�J�J����r�r�NzTask z with path z wrote to unknown channel z, ignoring it.)�sortedr��71setdefaultrer�rk�maxr�r8�consumerr�rhr1r7r9r0r:r.r/r�rH�warningra�setr��is_available�addr=�72isdisjoint�finish)
r�r�r��get_next_version�trigger_to_nodes�	bump_stepr�r��next_version�pending_writes_by_channel�val�updated_channels�valss
             r`�apply_writesr��s"��0
�5�A�B�E��.��.�.�I����?�#�.�.�t�y�y�"�=�D�D�!�M�M�
�)�D��&8�9�9�;��!3�4�T�:�:�)�
�	73������'��0�1��J�1�2�9�9�;�<���
74�����D��M�M�D��x��	
�%)�$4�	
�!�	
�����>�!�!�#�#��(@�3?�)�*�4�0��7B�$�6G�������I�D��������!�����!�)�/�6�6�s�;�����D�I�I�;�k�$�)�)��<V�W[�V\�\j�k��%��("%���/�5�5�7�75�����~�$�$�T�*�*�|�/G�7C�-�.�t�4��>�.�.�0�0�$�(�(��.�
8���D��~�*�*�,�,��1M��>�(�(��3�3��8P�;G�1�2�4�8��~�2�2�4�4�(�,�,�T�2�
��%�0�0�1A�B�B��D��~�$�$�&�&�<�+C�7C�-�.�t�4��>�.�.�0�0�$�(�(��.�����c
��*s�L876�)L877�:L=�L=�#78L=r])�store�checkpointer�managerr�r�r�r�c��gr\r]�r��pending_writes�	processesr�r�r��step�stop�
for_executionr�r�r�r�r�r�r�s                r`�prepare_next_tasksr�\s��& rc)r�r�r�r�c��gr\r]r�s                r`r�r�rs��&'*rcc��0n[R"USRSS55n[U5n/n[	[79[S-UR[55nU(a�UR5(a�[UR55Hdunn[[U4S40SU_SU_SU_SU_S	U_S80U_SU_SU_S
U_SU_SU_SU	_SU81_SU_SU_SU_SU_6=n(dMSURU5 Mf U
(aQU(aJ[5nU
H.nURU5=n(dMURU5 M0 [!U5nOUS(dSnOUR#5nUHan[[$U4S40SU_SU_SU_SU_S	U_S82U_SU_SU_S
U_SU_SU_SU	_SU83_SU_SU_SU_SU_6=n(dMPURU5 Mc UVs0sHnUR&U_M sn$s snf)aPrepare the set of tasks that will make up the next Pregel step.84 85Args:86    checkpoint: The current checkpoint.87    pending_writes: The list of pending writes.88    processes: The mapping of process names to PregelNode instances.89    channels: The mapping of channel names to BaseChannel instances.90    managed: The mapping of managed value names to functions.91    config: The `Runnable` configuration.92    step: The current step.93    for_execution: Whether the tasks are being prepared for execution.94    store: An instance of BaseStore to make it available for usage within tasks.95    checkpointer: `Checkpointer` instance used for saving checkpoints.96    manager: The parent run manager to use for the tasks.97    trigger_to_nodes: Optional: Mapping of channel names to the set of nodes98        that are can be triggered by that channel.99    updated_channels: Optional. Set of channel names that have been updated during100        the previous step. Using in conjunction with trigger_to_nodes to speed101        up the process of determining which nodes should be triggered in the next102        step.103 104Returns:105    A dictionary of tasks to be executed. The keys are the task ids and the values106    are the tasks themselves. This is the union of all PUSH tasks (Sends)107    and PULL tasks (nodes triggered by edges).108�id�-�Nr��checkpoint_id_bytes�checkpoint_null_versionr�r�r�r�r�r�r�r�r�r�r��input_cacher�r�r�r])�binascii�	unhexlify�replacer�rr@rTr�r;r��	enumerate�prepare_single_taskr7r�r�r�r��keysr6r�)r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r��
tasks_channel�idx�_r��triggered_nodesr��node_ids�candidate_nodesrer�s                              r`r�r��s���Z46�K�"�,�,�Z��-=�-E�-E�c�2�-N�O��*�:�6�L�57�E���t��t�+�X�\�\�%�-@�A�M���3�3�5�5��
� 1� 1� 3�4�F�C��*��s����&��%8�	�109)5�� .�
�$��"�� ��������,����*��  �!�"(�#�$*�%�&*�'��t��*���T�"�-5�>�,�$'�E��'�G�+�/�/��8�8�x�8��&�&�x�0�(�*0��)@��
�*�
+���#�.�.�*�� ��&�
�4�L��110�"�111�!4�	112�113%1�114�*�
115� �116��117��118��119��120��121�(�122��123�&�124� �!125�"$�#126�$&�%127�&&�'128�129�4�130�*
�L�L���- �.#�#�U��A�D�D�!�G�U�#�#��#s�#G=c��\rSrSrSSjrSrg)�	_TaskIDFnic��gr\r])r_�	namespace�partss   r`�__call__�_TaskIDFn.__call__s��rcr]N�r�bytesrzstr | bytesrmro)rrrsrtrurrxr]rcr`rrs��
rcr)r�r�r�r�r�r�c��131�U	R[05nUR[S5nUSS:�a[O[nUS[132:Xa}[
US[5(ae[[[[[[[[4U5U40SU_SU_SU_S	U_S133U_SU	_SU134_S
U_SU_SU
_SU_SU_SU_SU_SU_SU_6$US[135:XaY[[[[[4U5U40SU_SU_SU_S	U_S136U_SU	_SU137_SU_S
U_SU_SU
_SU_SU_SU_SU_SU_SU_6$US[:XGa�[[US5nUU;agUUnUcg[UUSUSRU5UU5(Ga�[[!UR"55nU(aU[$U3OUnU"UU[U1385U[/UQ76nU[&U3n[)U	[R[*5UU[-UR/55U	[R[05U139U5n[3UUUUUUS9nU[4LagU140UUUSSUS.nUbUU:XdUS U35eU(Ga�UR<=n (Ga�UR>(aURAUR>5 [C5n!URD=(d UnU(apURGU5n"[I[J[MU5=(d S!U4[-[
U"[5(aU"R/5OU"5URN5n#OSn#[[PUR[R[T55n$U$RWUS"R[XS5U
[[US#UUUR[\5U	RS$5=n%(a[U%5OSS%9S&9n$UUR^S'.n&[aUUU U![c[eU	[[fU&55UU(aURiS(U14135OS[jU[lU!Rn[p[s[tUUU[wUSSUU!U55[xU=(d UR[x5[z0UR[z05EUUS#0E[|S[U[*U[RU$0	S)9UUR~=(d UU#UUSSUR�UR�UR�S*9
$g[�UUUSS5$gg![6a,n[8(aUR;SUSUSSS35 eSnAff=f)+z�Prepares a single task for the next Pregel step, given a task path, which142uniquely identifies a PUSH or PULL task within the graph.r�r�r�r�����r�r�r�r�r�r�r�r�r�r�r�r�r�r��	parent_ns�task_id_funcr�Nr�r�)r�r�r�zBefore task with name 'z' and path 'rV�'��langgraph_step�langgraph_node�langgraph_triggers�langgraph_path�langgraph_checkpoint_ns� != �__dynamic__�channel_valuesr��run_id��
checkpoint_id�
checkpoint_ns�task_id�	thread_idr)�previousr��execution_info��metadatar��graph:step:��run_namer��configurable��writers�	subgraphsr�)Dr�r!r$�_xxhash_str�143_uuid5_strr7r�r~�prepare_push_task_functionalr�tuplero�int�prepare_push_task_sendr6�	_triggersr�rkr3r2�_scratchpadr*r�encoder(�_proc_inputr>�	Exception�SUPPORTS_EXC_NOTES�add_note�noder r�rr��key_funcrOr rF�ttlrMr)rK�overrider5rLr-r�rQrrr�	get_childr,r+�extendr'rr�rzr%r#r"r��flat_writersr'r�rR)'�	task_path�task_id_checksumr�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r$rrre�procrkrr�task_checkpoint_nsr�r��excr r5rh�args_key�	cache_key�runtime�rid�additional_configs'                                       r`r�r�s���0�:�:�d�B�'�L�� � �!9�2�>�I�",�S�/�A�"5�;�:�L���|�t��144�9�R�=�$� ?� ?�+���s�E�3��T�1�2�I�>��145�"�146�!4�	147�148*�149��
150��151��152��153��154�(�155��156�&�157��158�&�159� &�!160�" �#161�$&�%162�	163�*164�1���	�%���s�E�z�"�I�.��165�"�166�!4�	167�168*�169��
170��171��172��173� �174��175�(�176��177�&�178��179� &�!180�"&�#181�$ �%182�&&�'183�	184�,185�1���	��C��1��&���y� ������"�*�����)�*���'�+�+�D�1�#��186�187��V�D�M�M�2�3�H�<E�y�k�&��$��8�4�M�"�#���D�	�����
�G�%2�?�6�(�7�)�!D��$��t�� � �!6�7���"�#5�#<�#<�#>�?��t�� � �!6�7����J�
�!����"/� +�)�
���'�>��"�#'�"&�&.�"+�B�Q�-�+=��H� �+��"2�2�V�w�i�t�DT�CU�4V�V�2���9�9�$�4�$��}�}� ����
�
�6�5:�W�F�#'�#4�#4�#D��L�#�#/�#8�#8��#=��$,� /�!+�D�!1�!B�]� $��188/�(2�(�C�'@�'@�%-�O�O�$5�)1�	�)�,�,�%�	� %)�	�"���!1�!1�2D�o�!V��G�&�.�.�!+�,<�!=�!A�!A�(�D�!Q�#�'4�*4�T�*:�*<�$+�&2�&6�&6�7K�&L�7=�z�z�(�7K�0K��0K�3�s�8�RV�(�/�189�G�%-� $�	�	�)�%�0�����$�)� &��^�=N�(O��&*�$+�!(� 1� 1�K��v�2F� G�%)�!3�G� /���� /��$.�$.�$,�$+�$4�(1�"�1�
�(,�(.�(0�	%&�2"�!8�$0�%Q�'3�'7�'7�8O�'P� 9�<"�&2�&6�&6�7P�RT�&U�<"�$-�z�$�/?�<"�!9�$� 8�:L� 5�z� 2�G�7*�'�P!��)�)�9�\�!��!�"�1�
� $� 1� 1�"&�.�.� $���i5�5�U%�B"�'�4��2�A��?�?�w190�191��d�
�%�%��L�L�1�$��|�I�b�q�M�?�RS�T����
�s�T1�1192U'�;'U"�"U'c�X�[U[5(aU$[[U55$r\)r��
BaseExceptionr2ro)�values r`�_coerce_pending_errorrI�s#���%��'�'����S��Z� � rcc�n�/nUH,up#nU[:XdMUR[U55 M. U$r\)r.r�rI)r��errorsr�r�rHs     r`� _read_errors_from_pending_writesrLs9��#%�F�+���E��e���M�M�/��6�7�,��Mrcc�j�[U5H$up#nX!:XdM
U[:XdM[U5s $ gr\)�reversedr.rI�r�r�pending_task_idr�rHs     r`�+_read_error_for_task_id_from_pending_writesrQs6��,4�N�+C�'��%��%�'�U�*:�(��/�/�,D�rcc��[U5H=up#nX!:XdM
U[:XdM[U[5(aUs $[U5s $ gr\)rNr/r�rorOs     r`�+_read_error_source_node_from_pending_writesrSsH��,4�N�+C�'��%��%�'�5F�*F��%��%�%����u�:��	,D�193rc)r�r�r�r�r�c���UR[05nUSn[UR5nURnUc[S5e[nU(aU[U3OUnU"UU[U5U[[US5[US55nUSU3n/USSQSP7nUUUUUS	.nUbUU:XdUS194U35eU195(Ga�[5nUR=(d UnU(a�UR"URS0URSD6n[[ [#UR5=(d S4[%['U[5(aUR)5OU5UR*5nOSn[-UR[.5UU[%UR)55UR[05UU	5n[3[4UR[6[855n U R;U[=US
UUUR[>5URS5=n!(a[U!5OSS9S9n [AUURUU[C[EUSU05UURF=(d U
(aU
RISU35OS[JU[LURN[P[S[TUUU[WUUUU55[XU=(d UR[X5[Z0UR[Z05EUUS
0E[\S[^U[.U[6U 0	S9UUR`=(d UUUUURbS9$[eUUU5$)zIPrepare a push task with an attached caller. Used for the functional API.r196Nz1`call` functions must have a `__name__` attributer���:rVTrrrrr�rr)r�rr r!r"r�)3r�r!rEr�re�197ValueError�PUSH_TRIGGERr3ror7r�rr�r6r�rOr rFrr�r0r7r/r*r(rrMr)rKr8rLr-rQrrr�r9r,r+r:r'rr�rzr%r#r"r$r�r�rR)"r<r=r�r�r�r�r�r�r�r�r�r�r�r�r�r�rrr$�call�proc_rerkrrr?�in_progress_task_pathr rhrArBr�rCrDs"                                  r`r*r* s~��0�:�:�d�B�'�L��R�=�D�!�$�)�)�,�E��:�:�D��|��L�M�M�*�H�4=�y�k�&��$��0�4�M�����D�	����i��l�#��I�a�L���G�*�?�!�G�9�5��3�i���m�2�T�2����&�/�#5��H��#��*�*�N�w�i�t�<L�;M�,N�N�*��).����(�(�8�L���#�,�,�d�j�j��m�M�t�z�z�!�}�M�H�)1�#���	�	�*�;�m��#�)3�H�c�)B�)B�H�O�O�%���� � �	*�I��I� ����2�3����1�8�8�:�;����2�3���198�199��w�� 0� 0�1C�_� U�V���"�"��(�(��.�0��&�*�*�+?�@�+1�:�:�h�+?�$?�C�$?�s�3�x�d��#�	200��$���J�J�����f�z�8�&<�=���.�.�R�?F�G�%�%��D�6�&:�;�D�&��#�V�]�]�#�W�"�"� ��(�)>��f�h�W�&�,�$�Q��(8�(8�9P�(Q�-�0�&�*�*�+D�b�I�0�!�:�d�#3�0�-�d�,�.@�)�:�&��+�
�:
����-����!��L�L�O(201�(	202�T�'�4�)>�?�?rcc�203�[U5S:XGaL[[US5nU[R	5(dgU[R5nUS:dU[U5:�agUUn[
U[5(d$[R"S[U5S35 gURU;a%[R"SURS35 gUURnURnUcg[nU(aU[UR3OURnU"UU[U5UR[[U55nO[R"SU35 gUR[ 05nUSU3n/USS	QS204P7nUURUUUS.nUbUU:XdUSU35eU205(Ga%UR"(aUR%UR"5 ['5nUR(=(d UnU(a�UR+UR,5n [/[0[3U5=(d S
UR4[5[
U [5(aU R75OU 5UR85n!OSn![;U[ R[<5UU[5UR755U[ R[>5UU	5n"[[@UR[B[D55n#U#RGUUSR[HS5[KUSUUUR[L5URS5=n$(a[U$5OSS9S9n#UURNS.n%[QURUR,UU[S[UUU%5URU
(aU
RWSU35OS[XU[ZUR\[^[a[bU"UU[eUURUU55[fU=(d UR[f5[h0UR[h05EUUS0E[jS[lU[<U"[BU#0	S9UURn=(d UU!UUURpURrURtbURtS9
$URtS9
$[wUURU5$)NrUr�rzIgnoring invalid packet type z in pending sendszIgnoring unknown node name z Ignoring invalid PUSH task path rVrVFrrrrr�rr)r�rrrr!r"r%)<�lenrr,r;r�r�r�rTrHr�r�r5rXr3ror7r!r r�rr�r6�argrOr rFrr0r7r/r*r(rMr)rKr8r5rLr-r�rQrrr9r,r+r:r'rr�rzr%r#r"r$r�r;r'r�rR)&r<r=r�r�r�r�r�r�r�r�r�r�r�r�r�r�rrr�r��sends�packetr>�	proc_noderkrrr$r?�translated_task_pathr rhrArBr�rCrDrEs&                                      r`r-r-�s���.�9�~����3�	�!��%�����+�+�-�-�� (��� 3� 3� 5����7�c�S��Z�'���s����&�$�'�'��N�N�/��V��~�=N�O�
�
��;�;�i�'��N�N�8����
�EV�W�X������%���I�I�	������3<�y�k�&��&�+�+��/�&�+�+�	������I��K�K����H�
206��	���9�)��E�F���:�:�d�B�'�L�)�?�!�G�9�5��3�Y�r��]�2�E�2��� �+�+�&�.�#5��H��#��*�*�N�w�i�t�<L�;M�,N�N�*���=�=��O�O�D�M�M�*�).����(�(�8�L���#�,�,�V�Z�Z�8�H� �#���%�6���K�K��207#�)3�H�c�)B�)B�H�O�O�%���� � �208�I��I� ��4�L���2�3����1�8�8�:�;��4�L���2�3���209�210��w�� 0� 0�1C�_� U�V���"�"��� 0�1�5�5�h��E�(�(��.�0��&�*�*�+?�@�+1�:�:�h�+?�$?�C�$?�s�3�x�d��#�211212��!��I�I�-213��$��K�K��J�J�����f�&7�8����?F�G�%�%��D�6�&:�;�D�'��#�V�]�]�#�W�"�"� ��(�0�&�+�+�v�x��&�,�$�Q��(8�(8�9P�(Q�-�0�&�*�*�+D�b�I�0�!�:�d�#3�0�-�d�,�.@�)�:�&��/�

�@
����-���� ��%�%��n�n�&,�n�n�&@�F�N�N�Y-214�-	215�XGK�l�l�Y-216�-	217�^�'�6�;�;�0D�E�Ercc#�6�X;agXQnURnUcg[R"USRSS55nUSS:�a[O[218nUR
[05nUR
[S5nU(aU[U3OUnU"UU[U	5U[SUR5nUSU3n/URSS	QSPS219P7nU	U[UUS.nUR(aUR!UR5 [#5nUR$=(d UnUR&=(d UnU(azUR)UR*5n[-[.[1U5=(d SU4[3[5U[5(aUR75OU5UR85nOSn[;U[R
[<5UU[3UR755U[R
[>5U	U2205n [A[BUR
[D[F55n!U!RIX�S
R
[JS5S9n!UURLS.n"[OUUR*UU[SUU"5UU
(aU
RUSU	35OS[VU[XURZ[\[_[`U UU[cUUU[55[dU=(d UR
[d5[f0UR
[f05EUUS0E[hS[U[<U [DU![j[mURnUS90221S9[UUUUURpURrS9$)zEPrepare an immediate node-level error handler task for a failed task.Nr�r�r�r�r��node_error_handlerrVrVFrrr)r�rrr!)r5�errorr")r&r'):r5r�r�r�r(r)r�r!r$r3ror7r�rarXr r�rr�r�r6r�rOr rFrr�r0r7r/r*r(rrMr)rKr8r5r�rQrrr9r,r+r:r'rr�rzr%r#r"r&rCrer;r')#�failed_task�handler_node_name�failed_errorr�r�r�r�r�r�r�r�r�r�r�r�r�r>rar�rr$rrrr?rbr rh�effective_retry_policy�effective_cache_policyrArBr�rCrEs#                                   r`�prepare_node_error_handler_taskrkVs���(�)���'�D��	�	�I����"�,�,�Z��-=�-E�-E�c�2�-N�O��",�S�/�A�"5�;�:�L��:�:�d�B�'�L�� � �!9�2�>�I�5>�9�+�f�X�/�0�1�DU������D�	��������G�*�?�!�G�9�5��O�[�-�-�b�q�1�O�3G�O��O���+�*�.�#5��H��}�}�����
�
�&�%*�W�F�!�.�.�>�,��!�.�.�>�,���)�2�2�;�3D�3D�E�����D�!�2�]�!�
�222
�%/��#�%>�%>����!�H�
�
#�&�&�223224�	��	���t����.�/����-�4�4�6�7��t����.�/����J��7�L�,�,�-?��Q�R�G�����)9�:�>�>�x��N���G���	�	�)�� ���������&�"3�4�&�AH�g�'�'�+�d�V�(<�=�d�"�G�����������$�,�)��$�	�"�(� �M�L�$4�$4�5L�$M�)�,�"�&�&�'@�"�E�,��z�$�/�,�)�$�(�*<�%�z�"�G�%�y�$�)�)��(�5�	"	225�F	������!�!��.�.�]/�/rcc�X�USR5Hn[U5"5s $ g)z6Get the null version for the checkpoint, if available.r�N)r�r�)r�r�s  r`r�r��s,���0�1�8�8�:���G�}���;�rcc��Uc-URHnXR5(dM g gURHBnXR5(dMURXS5URXS5:�dMB g g)NTF)rkr�r�)r��versionsr�r�r>r�s      r`r.r.�sz���|��M�M�D��~�*�*�,�,��"���M�M�D��~�*�*�,�,�����2�����,�2-��	"�226rcc227�^^^�[T5S:�a�TH#nUS[:XdMUS[:XdM!Um O SmTH:nUSU:XdMUS[:XdMUSn[U[5(dU/n O /nAU(aX4;aXCn	URU	5 OSm/nSSUUU4Sjjjn228[
UU[5[5UU229[5S9$)Nrr�rUc�>�TcTbTRU5$gU(aTRT5 TS$TS$![a gf=f)NrU)�get_null_resume�removerW)r��null_resume_write�parent_scratchpadr�s ���r`rq�$_scratchpad.<locals>.get_null_resume(sf����$� �,�(�8�8��A�A���
��%�%�&7�8�(��+�+�!��#�#���
��
�s�=�230A231�	A232)r�r��call_counter�interrupt_counter�resumerq�subgraph_counter�F)r��boolrmr
)r]r4r9r�r�r�r<�LazyAtomicCounter)rtr�r�namespace_hash�233resume_mapr�r��w�task_resume_write�mapped_resume_writerqrss``         @r`r/r/s�����>��Q���A���t�|�#��!����$%�!�� �!%�� �A���t�w��1�Q�4�6�>�$%�a�D�!�!�"3�T�:�:�):�(;�%�� �!#��
��.�6�",�"<���$�$�%8�9��!����$�$��
�
�&�(�+�-� �'�*�,��rcc���Ub'URU;a[XPR5$[UR[5(a_0nURHLnXr;a/X'R5(aX'R
5Xg'M5M7XR
U5Xg'MN O�[UR[5(aZURU;aDX RR5(aX RR
5nO$[$[$[SUR35eU(aURbURU5nUbXeUR'U$)zLPrepare input for a PULL task, based on the process's channels and triggers.z2Invalid channels type, expected list or dict, got )�input_cache_keyr234r�r�r�r�r�ror>�RuntimeError�mapper)r>r�r�r�r�r�r�r�s        r`r1r1Ds;����4�#7�#7�;�#F��K� 4� 4�5�6�6��$�-�-��&�&� ���M�M�D����>�.�.�0�0� (�� 2� 2� 4�C�I�1�$�M�-�-�j�9��	�"�235�D�M�M�3�	'�	'��=�=�H�$��
�
�&�3�3�5�5��}�}�-�1�1�3�����N��@�����P�236�	237�238����0��k�k�#�����,/�D�(�(�)��Jrcc���[USS9nURSRSU555 UR5nUSSSUSSSUSS	SUS	S239SUS240S3	$)zAGenerate a UUID from the SHA-1 hash of a namespace and str parts.F)�usedforsecurityrcc3�p# �UH,n[U[5(aUR5OUv� M. g7fr\�r�ror0�r��ps  r`r��_uuid5_str.<locals>.<genexpr>ws'���O��A�j��C�&8�&8����241�a�?����46N�r����� )rr��join�	hexdigest)rr�sha�hexs    r`r)r)ssw���y�%�2420�C��J�J�s�x�x�O��O�O�P�243
�-�-�/�C��"�1�g�Y�a��A�b�	�{�!�C��2�J�<�q��R����A�c�"�R�j�\�J�Jrcc��[USRSU55-5nUSSSUSSSUSSSUSSSUSS	3	$)244z@Generate a UUID from the XXH3 hash of a namespace and str parts.rcc3�p# �UH,n[U[5(aUR5OUv� M. g7fr\r�r�s  r`r��_xxhash_str.<locals>.<genexpr>s'���T�e��:�a��+=�+=�Q�X�X�Z�1�D�e�r�Nr�r�r�r�r�r�)rr�)rrr�s   r`r(r(|sf��245��C�H�H�T�e�T�T�T��C��"�1�g�Y�a��A�b�	�{�!�C��2�J�<�q��R����A�c�"�R�j�\�J�Jrcc��[U[[45(aSSRSU553$[U[5(aUS$[U5$)z2Generate a string representation of the task path.�~z, c3�8# �UHn[U5v� M g7fr\)r�)r��xs  r`r�� task_path_str.<locals>.<genexpr>�s���4��1�m�A�&�&��r��010d)r�r+r�r�r,ro)�tups r`r�r��sa���c�E�4�=�)�)��D�I�I�4��4�4�5�6���c�3����D�z��246��X�rcc�8�\rSrSr%SrS\S'SSjrS	SjrSrg)247r|i���_counterzCallable[[], int] | Noner�c��SUlgr\r�r^s r`r��LazyAtomicCounter.__init__�s	����
rcc��URcQ[ URc%[R"S5RUlSSS5 UR5$UR5$!,(df   UR5$=f)Nr)r��LAZY_ATOMIC_COUNTER_LOCK�	itertools�count�__next__r^s r`r�LazyAtomicCounter.__call__�sd���=�=� �)��=�=�(�$-�O�O�A�$6�$?�$?�D�M�*��}�}���t�}�}���*�)��}�}���s�3A/�/248BN)rmr�)rmr,)	rrrsrtrur�r|r�rrxr]rcr`r|r|�s���I�&�&��rcr|c	�4�[UR[5(dU$URR5VVs0sH-up#[UR	U5[2495(aM+X#_M/ nnn[
URX@RS9$s snnf)z�Pop any values belonging to UntrackedValue channels in Send.arg for safe checkpointing.250 251Send is often called with state to be passed to the dest node, which may contain252UntrackedValues at the top level. Send is not typed and arg may be a nested dict.)r5r^r�)	r�r^�dictr�r�rArTr5r�)r`r�r�r��
sanitized_args     r`�!sanitize_untracked_values_in_sendr��s}���f�j�j�$�'�'��
�253�J�J�$�$�&��&�D�A��(�,�,�q�/�>�:�	
���&���254�V�[�[�m�^�^�L�L��s�*B�-B)r�rr�zAll | Sequence[str]r�zIterable[PregelExecutableTask]rmzlist[PregelExecutableTask]rz)r�r<r��Mapping[str, BaseChannel]r�rDr�rYr�zlist[str] | strr�r{rmzdict[str, Any] | Any)r�z255int | Noner�r�rmr,)r�rr�r�r�zIterable[WritesProtocol]r�zGetNextVersion | Noner�zMapping[str, Sequence[str]]rmzset[str])"r�rr��list[PendingWrite]r��Mapping[str, PregelNode]r�r�r�rDr�rr�r,r�r,r�zLiteral[False]r��
Literal[None]r�r�r�r�r��"Mapping[str, Sequence[str]] | Noner��set[str] | Noner��Sequence[RetryPolicy]r�r�rmzdict[str, PregelTask])"r�rr�r�r�r�r�r�r�rDr�rr�r,r�r,r�z
Literal[True]r��BaseStore | Noner��BaseCheckpointSaver | Noner��/None | ParentRunManager | AsyncParentRunManagerr�r�r�r�r�r�r�r�rmzdict[str, PregelExecutableTask])"r�rr�r�r�r�r�r�r�rDr�rr�r,r�r,r�r{r�r�r�r�r�r�r�r�r�r�r�r�r�r�rmz7dict[str, PregelTask] | dict[str, PregelExecutableTask])(r<ztuple[Any, ...]r=�256str | Noner�rr�rr��V | Noner�r�r�r�r�r�r�rDr�rr�r,r�r,r�r{r�r�r�r�r�r�r��&dict[INPUT_CACHE_KEY_TYPE, Any] | Noner�r�r�r�rmz(None | PregelTask | PregelExecutableTask)rHr
rmrG)r�r�rmzlist[BaseException])r�r�rrormzBaseException | None)r�r�rrormr�)&r<z!tuple[str, tuple, int, str, Call]r=r�r�rr�rr�r�r�r�r�rDr�rr�r,r�r,r�r{r�r�r�r�r�r�r�r�r�r�rrorrrmz!PregelTask | PregelExecutableTask)(r<ztuple[str, tuple]r=r�r�rr�rr�r�r�r�r�rDr�rr�r,r�r,r�r{r�r�r�r�r�r�r�r�r�r�rrorrr�r�rmz(PregelTask | PregelExecutableTask | None)"rfrQrgrorhrGr�rr�r�r�r�r�r�r�rDr�rr�r,r�r,r�r�r�r�r�r�r�r�r�r�rmzPregelExecutableTask | None)r�rrmr�)r�r�rnrr�zChannelVersions | Noner�rr>rJrmr{)rtzPregelScratchpad | Noner�r�rror}ror~zdict[str, Any] | Noner�r,r�r,rmr<)r>rJr�rDr�r�r�r{r�r<r�r�rmr
r)r�zstr | int | tuplermro)r`rTr�r�rmrT)��257__future__rr�r��sys�	threading�collectionsrr�collections.abcrrrr	r258�	functoolsr�hashlibr�typingr
rrrrr�langchain_core.callbacksr� langchain_core.callbacks.managerrr�langchain_core.runnables.configr�langgraph.checkpoint.baserrrrr�langgraph.store.baser�xxhashr�langgraph._internal._configrr�langgraph._internal._constantsr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9r:r;�langgraph._internal._scratchpadr<�langgraph._internal._typingr=r>�langgraph.channels.baser?�langgraph.channels.topicr@�"langgraph.channels.untracked_valuerA�langgraph.constantsrB�langgraph.errorsrC�langgraph.managed.baserD�langgraph.pregel._callrErF�langgraph.pregel._iorG�langgraph.pregel._logrH�langgraph.pregel._readrIrJ�langgraph.runtimerKrLrM�langgraph.typesrNrOrPrQrRrSrTrU�GetNextVersion�version_infor3rYrzr~r�r�r�r�r�rXrr�rIrLrQrSr*r-rkr�r.r/r1r)r(r��Lockr�r|r�r]rcr`�<module>r�s�	��"���259��*�A�A������/�T�:���+�%�C���������<=�:�/�*�=�*�&�6�D�.�(�C�E�E�	�	�	��1�t�8�T�*�A�-�.���%�%��0��-�X�-�"�z�� � �F���(��*�� �	�N�
$� �$�'�$�!�$��	$�260
�$��
$��$�N5�261q��q�'�q�$�q�,�	q�2622�q��
q�h263� �"&�!�;?�(,�*,�"&�# �� �&� �(� �(�	 �264!� �
�
 �� �� �"� �� � � �� �9� �&� � (�! �" �# �$�% �265� �*266�<@�(,�*,�'+�#*��*�&�*�(�*�(�	*�267!�*�
�
*��*��*�!�*��*�-�*�=�*�9�*�&�*� (�!*�"%�#*�$%�%*�268�*�@#�/3�?C�;?�(,�*,�'+�#y$��y$�&�y$�(�y$�(�	y$�269!�y$�
�
y$��y$��y$��y$��y$�-�y$�=�y$�9�y$�&�y$� (�!y$�"%�#y$�$=�%y$�x�w��
��
�(#�/3�?C�:>�'+�*,�)m@��m@� �m@��	m@�270�m@�&�
m@�'�m@�(�m@�(�m@�!�m@�
�m@��m@��m@��m@��m@� -�!m@�"=�#m@�$8�%m@�&%�'m@�((�)m@�*.�+m@�`!��&�����&��14�����&��14����2#�/3�?C�'+�*,�%G@�0�G@�!�G@�271�G@��
G@�'�G@�(�G@�!�G@�
�G@��G@��G@��G@��G@�-�G@� =�!G@�"%�#G@�$(�%G@�&�'G@�*�+G@�,'�-G@�p#�/3�?C�'+�*,�%iF� �iF�!�iF�272�iF��
iF�'�iF�(�iF�!�iF�
�iF��iF��iF��iF��iF�-�iF� =�!iF�"%�#iF�$(�%iF�&�'iF�(�)iF�*(�+iF�,.�-iF�r#�/3�?C�'+�*,�#J�%�J��J� �	J�273�J�'�
J�(�J�(�J�!�J�
�J��J��J��J�-�J�=�J� %�!J�"(�#J�$!�%J�Z���
���'����!���	�274��275�
�(A�.�A�&�A��A��	A�276&�A��
A��A��A�H,�277�,�
 �,�(�,�278�,�!�
,�8�,�	�,�^K�K��%�>�>�+��
�
� M��M�5�M�	�Mrc
codekingpro/portable-devtools · Team Ai