Team Ai
Datasetpublic

codekingpro/portable-devtools

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

2��jC:���SSKJr SSKrSSKrSSKrSSKJrJr SSK	J3r4JrJrJ
r
 SSKJrJrJrJr SSKJrJr SSKJr SSKJr SS	KJrJrJrJr SS5KJrJ r  SSK!J"r" SSK#J$r$ SS
K%J&r&J'r'J(r(J)r)J*r*J+r+J,r, SSK-J.r. SSK/J0r0J1r1 SSK2J3r3 SSK4J5r5J6r6J7r7J8r8J9r9J:r:J;r;J<r<J=r=J>r>J?r?J@r@JArAJBrBJCrCJDrDJErEJFrFJGrGJHrHJIrIJJrJ SSKKJLrL SSKMJNrN SSKOJPrPJQrQ SSKRJSrSJTrTJUrU SSKVJWrW SSKXJYrY SSKZJ[r[ SSK\J]r] SSK^J_r_J`r` SSKaJbrbJcrc SSKdJereJfrfJgrgJhrhJiriJjrjJkrkJlrlJmrmJnrnJoroJprp SSKqJrrrJsrsJtrtJuruJvrvJwrw SSKxJyryJzrzJ{r{ SSK|J}r}J~r~JrJ�r�J�r� SS K�J�r� SS!K�J�r�J�r� SS"K�J�r�J�r�J�r� SS#K�J�r�J�r� SS$K�J�r�J�r� SS%K�J�r�J�r�J�r�J�r�J�r�J�r�J�r�J�r�J�r� \"S&5r�\0"S'5r�\
\�\�\4r�S/S(jr�"S)S*5r�"S+S,\�\5r�"S-S.\�\5r�g)0�)�annotationsN)�defaultdict�deque)�Callable�Iterator�Mapping�Sequence)�AbstractAsyncContextManager�AbstractContextManager�AsyncExitStack�	ExitStack)�datetime�timezone)�	signature)�
TracebackType)�Any�Literal�TypeVar�cast)�AsyncParentRunManager�ParentRunManager)�RunnableConfig)�	BaseCache)�WRITES_IDX_MAP�BaseCheckpointSaver�ChannelVersions�6Checkpoint�CheckpointMetadata�CheckpointTuple�PendingWrite)�	BaseStore)�	ParamSpec�Self)�patch_configurable)�CONF�CONFIG_KEY_CHECKPOINT_ID�CONFIG_KEY_CHECKPOINT_MAP�CONFIG_KEY_CHECKPOINT_NS�CONFIG_KEY_REPLAY_STATE�CONFIG_KEY_RESUME_MAP�CONFIG_KEY_RESUMING�CONFIG_KEY_RUNTIME�CONFIG_KEY_SCRATCHPAD�CONFIG_KEY_STREAM�CONFIG_KEY_TASK_ID�CONFIG_KEY_THREAD_ID�ERROR�ERROR_SOURCE_NODE�INPUT�	INTERRUPT�NS_END�NS_SEP�NULL_TASK_ID�PUSH�RESUME�TASKS)�ReplayState)�PregelScratchpad)�	EMPTY_SEQ�MISSING)�GraphInterruptEvent�GraphLifecycleEvent�GraphResumeEvent)�BaseChannel)�DeltaChannel)�UntrackedValue)�7TAG_HIDDEN)�EmptyInputError�GraphInterrupt)�ManagedValueMapping�ManagedValueSpec)�Call�GetNextVersion�PregelTaskWrites�apply_writes�checkpoint_null_version�	increment�prepare_next_tasks�prepare_node_error_handler_task�prepare_single_task�!sanitize_untracked_values_in_send�should_interrupt�
task_path_str)�achannels_from_checkpoint�channels_from_checkpoint�copy_checkpoint�create_checkpoint�delta_channels_to_snapshot�empty_checkpoint)�AsyncBackgroundExecutor�BackgroundExecutor�Submit)�map_command�	map_input�map_output_updates�map_output_values�
read_channels)�8PregelNode)�get_new_channel_versions�is_xxh3_128_hexdigest)�map_debug_checkpoint�map_debug_task_results�map_debug_tasks)�StreamChunk�StreamProtocol)�9RunControl�Runtime)	�All�CachePolicy�Command�10Durability�	Interrupt�PregelExecutableTask�RetryPolicy�Send�11StreamMode�V�Pc	�^�SU4Sjjn[UTVVs1sHo"RHo3iM M snn5$s snnf)Nc�R>�TH nUSUR;dMU"U5 M" g)N�)�modes)�value�stream�streamss  ��\D:\code\apps\devtools\python\user_packages\Python313\site-packages\langgraph/pregel/_loop.py�__call__�DuplexStream.<locals>.__call__�s$����F��Q�x�6�<�<�'��u�
��)r}rj�return�None)rkr|)rr��s�modes`   r��DuplexStreamr��s3����12�(�7�$O�7�a�w�w�t�T�w�T�7�$O�P�P��$Os�;c���\rSrSr%S\S'S\S'S\S'S\S	'S\S13'S\S'S
\S'S\S'S\S'S\S'S\S'S\S'S\S'S\S'S\S'S\S'S\S'S\S 'S!\S"'S#\S$'S%\S&'S'\S('S)\S*'S\S+'S,\S-'S.\S/'S0\S1'S2\S3'S4rS5\S6'S4rS5\S7'S4rS8\S9'S\S:'S;rS\S<'S=\S>'S?\S@'SA\SB'SC\SD'S\SE'SF\SG'SH\SI'SJ\SK'SL\SM'SN\SO'SP\SQ'SR\SS'S4r	ST\SU'S4r14SV\SW'SX\SY'S\SZ'\\S4S4S[S4S;S\.SuS]jjrS[S^.SvS_jjr
SwS`jrSxSajrSySbjrSzS{ScjjrS|SdjrS|SejrS}SfjrSySgjrS~ShjrS~SijrSSjjrSySkjrS�SljrS�SmjrS�SnjrSySojrS�SpjrS�SqjrS;Sr.S�Ssjjr Str!g4)��15PregelLoop�r�config�BaseStore | None�store�StreamProtocol | Noner~�int�step�stop�16Any | None�inputzBaseCache[WritesT] | None�cache�BaseCheckpointSaver | None�checkpointer�Mapping[str, PregelNode]�nodes�,Mapping[str, BaseChannel | ManagedValueSpec]�specs�str | Sequence[str]�17input_keys�output_keys�stream_keys�bool�is_replaying�	is_nested�/None | AsyncParentRunManager | ParentRunManager�manager�All | Sequence[str]�interrupt_after�interrupt_beforerq�18durability�Sequence[RetryPolicy]�retry_policy�CachePolicy | None�cache_policyrK�checkpointer_get_next_versionz4Callable[[RunnableConfig, WritesT, str], Any] | None�checkpointer_put_writes�)checkpointer_put_writes_accepts_task_pathzjCallable[[concurrent.futures.Future | None, RunnableConfig, Checkpoint, str, ChannelVersions], Any] | None� _checkpointer_put_after_previous�#Callable[[Checkpoint], None] | None�_migrate_checkpointr^�submitzMapping[str, BaseChannel]�channelsNzlist[Any] | None�_delta_write_futs�_error_handler_write_futsz&list[tuple[int, str, str, Any]] | None�_exit_delta_writes�_initial_checkpoint_configF�_has_persisted_parentrH�managedr�19checkpoint�str�checkpoint_id_savedztuple[str, ...]�
checkpoint_ns�checkpoint_configr�checkpoint_metadatazlist[PendingWrite]�checkpoint_pending_writeszdict[str, str | float | int]�checkpoint_previous_versionszRunnableConfig | None�prev_checkpoint_configzfLiteral['input', 'pending', 'done', 'draining', 'interrupt_before', 'interrupt_after', 'out_of_steps']�statuszRunControl | None�controlzdict[str, PregelExecutableTask]�taskszNone | dict[str, Any] | Any�output�set[str] | None�updated_channelszdeque[GraphLifecycleEvent]�_graph_lifecycle_events�_has_graph_lifecycle_callbacks�)r�r�r��migrate_checkpointr�r��has_graph_lifecycle_callbacksc20�&�X lX0lX@lSUlSUlXlX`lXPlXplX�l	X�l21X�lX�lX�l
X�lUUl[ URR#[$05;Ul[(U[$;UlUUlX�lUUlUUlX�lUUllURb:[<U[$;a)[?URU[$[<5UlU[$R#[@5n[CU[D5(aeURG5=n(aN[IUR[J[LRN"U[$[J[QU54505UlUR&(dHU[$R#[J5(a'[IUR[JS[(S05Ul[RUR[$;a�UR[$R#[J5UR[$[R;aU[IUR[(UR[$[RUR[$[J05Ul*OURUl*URT[$R#[V5=n(a?[CU[P5(d*[IURT[V[QU505Ul*UR[$R#[J5(aD[Y[[[PUR[$[J5R][L55OSUl/SUl0UR[$R#[b5n[CU[d5(aURfUl3gSUl3g)Nr�r�)4r~r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r/�getr%r�r&r�r��trigger_to_nodesr�r�r�r�rr�r.r�r-�22isinstancer<�subgraph_counterr$r(r6�joinr�r'r�r0�tupler�splitr�r�r,rmr�)�selfr�r~r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r��23scratchpad�cnt�	thread_id�runtimes                         r��__init__�PregelLoop.__init__24s&��0�����25���	���	��26�(���27��28��29�$��&��&��.�� 0�����+�t�{�{���t�R�/H�H���4��t��D���#5�� � 0��(���(���$��.K��+�',�w��$��;�;�"�'8�F�4�L�'H�&�t�{�{�F�4�L�AR�4S�T�D�K�.4�T�l�.>�.>�?T�.U�30��j�"2�3�3�!�1�1�3�3�s�3�0��K�K�0�&�+�+� &�t��-E� F� #�C���3��31����~�~�&��,�"2�"2�3K�"L�"L�,����)�2�/G��N��D�K�32
&����T�):�:����D�!�%�%�&>�?��{�{�4� �!:�;�<�&8����,�d�k�k�$�.?�1�/��k�k�$�'�(@�A�/C��&�D�"�&*�[�[�D�"��.�.�t�4�8�8�9M�N�N�9�N��i��-�-�);��*�*�)�3�y�>�:�*��&��{�{�4� �$�$�%=�>�>�
�$�s�D�K�K��-�.F�G�H�N�N�v�V�W��	
��33'+��#��+�+�d�#�'�'�(:�;��*4�W�g�*F�*F�w�����D��r���34interruptsc35�~�URS:Xa[S5eURnUS:Xa=URR[	SUUR36SURS95 gUS:Xa>URR[SUUR37SURUS95 gSU3n[U5e)	N�drainingz,Draining status cannot emit lifecycle events�resume�id)�run_idr��
checkpoint_idr��	interrupt)r�r�r�r�r�z$Unknown graph lifecycle event type: )	r��RuntimeErrorr��appendrAr�r�r?�AssertionError)r��kindr�r��msgs     r��_push_graph_lifecycle_event�&PregelLoop._push_graph_lifecycle_eventps����;�;�*�$��M�N�N������8���(�(�/�/� ��!�"&�/�/�$�"7�"&�"4�"4�	�
��[�
 ��(�(�/�/�#��!�"&�/�/�$�"7�"&�"4�"4�)��
�9���?�C� ��%�%r�c�Z�UR(dgURR5$�N)r��popleft�r�s r��_pop_lifecycle_event�PregelLoop._pop_lifecycle_event�s#���+�+���+�+�3�3�5�5r�c	�.^^�U(dg[SU55(a-[UVs0sHo3SU_M38 snR55nT[:XaqTRVs/sHnUST:wdUS[39;dMUPM snTlTRVs/sHo3ST:XdM
USSPM sn[U5-nO.TRVs/sHo3ST:wdM
UPM snTlUn[
STRR555(a~UVVs/sHoupV[TRRU5[5(aM5U[:Xa-[U[5(aU[UTR54OXV4PMq nnnTRRU4SjU55 TR S:wGa}TR"Gbo[%TR&[(TR*[,R[(S5[.TR0S	05nTR2(ak[5TS405(aTR6RT5nOSnTR9TR"UUTU(a[;UR<5OS5n	OTR9TR"UUT5n	TR>b5[
U4SjU55(aTR>RAU	5 TRBb2[
SU55(aTRBRAU	5 [5TS415(aTRETU5 ggs snfs snfs snfs snfs snnf)
�3Put writes for a task, to be read by the next tick.Nc3�8# �UHoS[;v� M g7f)rN)r)�.0�ws  r��	<genexpr>�(PregelLoop.put_writes.<locals>.<genexpr>�s���6�v�!��t�~�%�v���rr{c3�B# �UHn[U[5v� M g7fr��r�rD�r��channels  r�r�r��s���42�?U�G�J�w��/�/�?U���c3�0># �UHupTX4v� M
 g7fr�r�)r��c�v�task_ids   �r�r�r��s����-Q�&�$�!�w��o�&�s��exitr�r�r�c3�z># �UH0up[TRRU5[5v� M2 g7fr�)r�r�r�rC)r�r�_r�s   �r�r�r��s-����:�HV���43�4�:�:�>�>�!�,�l�;�;��s�8;c3�8# �UHupU[:Hv� M g7fr�)r2)r�rrs   r�r�r��s���B�39�4�1��&�&�6�r�)#�all�list�valuesr7r�r�anyr�r�r�r�rDr:rurS�extendr�r�r$r�r(r�r%r&r�r��hasattrr�r�rU�pathr�r�r��
output_writes)44r�r�writesr��writes_to_saverrr��task�futs45``        r��46put_writes�PregelLoop.put_writes�sG������6�v�6�6�6��F�3�F�q�Q�4��7�F�3�:�:�<�=�F��l�"��7�7�.�7�A��Q�4�7�?�a��d�.�&@��7�.�D�*� $�=�=�'�=�!�1������!�"��=�'��V��'�N� �9�9�.�9�a�q�T�W�_��9�.�D�*�$�N��47�?C�}�}�?S�?S�?U�48�49�50�+�51�+�D�A�!�$�*�*�.�.��"3�^�D�
 ��E�z�j��D�&9�&9��9�!�T�]�]�K�L��� �+�
�52�	
�&�&�-�-�-Q�&�-Q�Q��?�?�f�$��)E�)E�)Q�'��&�&�,�d�k�k�$�.?�.C�.C�0�"�/�-�d�o�o�d�.C�	��F��=�=��4��)�)��:�:�>�>�'�2�D��D��k�k��0�0��"��04�M�$�)�)�,�"����k�k��0�0��"��	���%�%�1�c�:�HV�:�7�7��&�&�-�-�c�2��-�-�9�c�B�39�B�?�?��.�.�5�5�c�:��4��!�!����w��/�"��]4��.��53'��54.��55s5�M=�'N�N�!N�1	N�N�(N�,4N�$>Nc56���URcgUR(dg[UR[UR57[R[S5[URS05n[[5nURHup4nX#RXE45 M UR5H�up6UR(ai[US5(aXUR RU5nUR#URUUUU(a[%UR&5OS5 MUR#URUUU5 M� g)Nr�r�r�)r�r�r$r�r(r�r%r�r&r�rrr��itemsr�rr�r�rUr)r�r��by_taskrrr}rrs        r��_put_pending_writes�PregelLoop._put_pending_writes�s+���'�'�/���-�-��#��"�"�(�$�+�+�d�*;�*?�*?�,�b�+�)�$�/�/�$�*?�	
�58���d�#��'+�'E�'E�#�G�e���#�#�W�$4�5�(F� '�}�}��O�G��=�=�'��g�C�C��z�z�~�~�g�.������0�0����04�M�$�)�)�,�"������0�0����	� /r�c59�6�[R"URSRSS55n[	UR5n[[S-[[URX!RU4S40SUR_SU_SU_SUR_S	UR_S60UR_SUR_SUR_S
UR _SUR"_SS_SUR$_SUR&_SUR(_SUR*_SUR,_65=n(a`UR/S[0U/5 X`R2UR'UR4(dUR7URU05 U$g)zEAccept a PUSH from a task, potentially returning a new task to start.r��-r�Nr��checkpoint_id_bytesrN�pending_writes�	processesr�r�r�r�r��
for_executionTr�r�r�r�r�r�)�binascii�	unhexlifyr��replacerNrrsrRr8rr�r�r�r�r�r�r�r�r�r�r�r�r��_emitrir�r��"_reapply_writes_to_succeeded_nodes)r�r�	write_idx�callr�null_version�pusheds       r��accept_push�PregelLoop.accept_pushs���'�0�0�����1F�1N�1N�s�TV�1W�X��.�t���?��� �4�'���t�y�y�)�W�W�d�;��
� �?�?�
�%8�	
�61)5�
� $�=�=�

��*�*�
����
����
��{�{�
��Y�Y�
��Y�Y�
�#�
��j�j�
�"�.�.�
� ���!
�""�.�.�#
�$"�.�.�%
�62�63�6�64�0
�J�J�w��&��:�$*�J�J�v�y�y�!��$�$��7�7����F�8K�L��M�?65r�c��[er���NotImplementedError�r��failed_task�errors   r��schedule_error_handler�!PregelLoop.schedule_error_handler=s66��"�!r�c��# �[e7fr�r/r1s   r��aschedule_error_handler�"PregelLoop.aschedule_error_handlerBs
���"�!���	c� �URUR:�aSUlg[URUR67URURURURURURSURURURURURURUR S9UlUR$b�UR'S[(0UR*E[,0UR*[,E[.URS0E0EURUR0UR2UR"R55UR68UR6UR8569 UR"(dSUlgUR:b#UR:R<(aSUlgUR>(d<UR70(a+URAUR"5 URC5 URD(aO[GURURDUR"R555(aS	Ul[I5eUR'S71[JUR"R555 UR"R55H;nURL(dMUROURPURLSS9 M= g)zaExecute a single iteration of the Pregel loop.72 73Returns:74    True if more iterations are needed.75�out_of_stepsFT)r"r�r�r�r�r�r�r��checkpointsr��doner�r�r���cached))r�r�r�rPr�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r&rgr�r%r&r�r�rr�r�r��drain_requestedr�r'�$_resume_error_handlers_if_applicabler�rTrGrirrr�)r�rs  r��tick�PregelLoop.tickGs_���9�9�t�y�y� �(�D�K��(��O�O��*�*��J�J��M�M��L�L��K�K��I�I��I�I���L�L��*�*��*�*�!�2�2�!�2�2��*�*��*�*�!76��77�(�0�0�<��J�J��$���,�,�����0�0��6��0�$�/�/�$�2G����
�
�� � ��(�(��78�79�!�!�#��.�.��+�+�� � �!
�(�z�z� �D�K���<�<�#����(D�(D�$�D�K��� � �T�%C�%C��3�3�D�J�J�?��5�5�7�� � �%5��O�O�T�2�2�D�J�J�4E�4E�4G�&80�&81�-�D�K� �"�"�	
�82�83�7�O�T�Z�Z�->�->�-@�A��J�J�%�%�'�D��{�{�{��"�"�4�7�7�D�K�K��"�E�(�r�c��URR5VVs/sHoRHo"PM M nnn[URUR84URR5URUR5UlURR[UR[5(a
UR4OUR5(d,URS[URX0R855 URbnUR H^upEn[UR"R%U5[&5(dM6URR)UR*XEU45 M` UR R-5 SUlUR1SS05 UR2(aO[5URUR2URR55(aSUlUR:[<R?[@S5 gs snnf)NrF�source�loopr�)!r�rrrMr�r�r�r�r��86isdisjointr�r�r�r&rbr�r�r�r�rCr�r��clearr��_put_checkpointr�rTr�rGr�r%�popr+)r��tr�r�tid�chrs       r��87after_tick�PregelLoop.after_tick�s���!�Z�Z�.�.�0�C�0��(�(�Q�!�(�!�0��C� ,��O�O��M�M��J�J�����.�.��!�!�!88����$�$�/�/��$�*�*�C�0�0��
�
���!�!�89�90�91
�J�J��+�T�-=�-=�v�}�}�
��"�"�.�"�<�<�92����d�j�j�n�n�R�0�,�?�?��+�+�2�2�D�I�I�s��3J�K�=�	
�&�&�,�,�.�!������h��/�0����$4��O�O�T�1�1�4�:�:�3D�3D�3F�%93�%94�,�D�K� �"�"����D����1�4�8��IDs�Ic��[er�r/r�s r��match_cached_writes�PregelLoop.match_cached_writes�s��!�!r�c��# �[e7fr�r/r�s r��amatch_cached_writes�PregelLoop.amatch_cached_writes�s���!�!�r9c���URHXup#nU[[[[4;aM"URU5=n(dM<URRX445 MZ g)a95Restore successful channel writes from checkpoint to in-memory tasks.96 97Skips control signals (ERROR, ERROR_SOURCE_NODE, INTERRUPT, RESUME)98so that failed/interrupted tasks remain with empty writes and will be99re-executed (or routed to error handlers) by the runner.100N)r�r1r2r4r9r�rr�)r�r�rL�krrs      r�r'�-PregelLoop._reapply_writes_to_succeeded_nodes�sT���7�7�I�C�A��U�-�y�&�A�A���y�y��~�%�t�%����"�"�A�6�*�	8r�c�$^	�0nURH;um	p#U[:XdM[U	4SjUR5S5nUcM7XAT	'M= UR5GH-upTURRU5nUcM&URURRnU(dMRURR[U45 [U4UUURURURURURUR UR"UR$UR&UR(UR*UR,UR.S.6nUcGMX�RUR0'GM0 g)u�On resume, schedule error handlers for tasks that failed in a prior run.101 102Called right after ``_reapply_writes_to_succeeded_nodes`` during ``tick()``.103At that point, ``_reapply_writes_to_succeeded_nodes`` has already skipped104ERROR / ERROR_SOURCE_NODE writes, so a previously-failed task still has105empty ``writes``.  Without intervention the runner (which executes only106tasks where ``not t.writes``) would re-run the original node.107 108This method prevents that re-execution for nodes that have an error109handler:110 1111. Scan ``checkpoint_pending_writes`` for ERROR_SOURCE_NODE markers112   persisted by a prior ``commit()``.  Each marker means "this task113   already failed and was routed to an error handler".1142. For each such task, write ``(ERROR, error)`` into ``task.writes``115   so the task is no longer empty — the runner will skip it.1163. Prepare a fresh error-handler task and add it to ``self.tasks``.117   Because the handler task starts with empty ``writes``, the runner118   will pick it up and execute it.119c3�V># �UHupnUT:XdMU[:XdMUv� M  g7fr�)r1)r�rKrrrLs    �r�r��BPregelLoop._resume_error_handlers_if_applicable.<locals>.<genexpr>�s1�����'E�G�A�!���8��()�U�120���'E�s�
)�)�	)N��handler_node_name�failed_errorr�r r!r�r�r�r�r�r�r�r�r�r�)r�r2�nextrr�r�r��name�error_handler_noderr�r1rQr�r�r�r�r�r�r�r�r�r�r�r�)121r��failed�chan�valr3rr�handler_node�handler_taskrLs122         @r�rA�/PregelLoop._resume_error_handlers_if_applicable�sM���,,.��"�<�<�N�C���(�(���'+�'E�'E��123�
���$�"'�3�K�=�%�l�l�n�N�G��:�:�>�>�'�*�D��|���:�:�d�i�i�0�C�C�L����K�K����u�~�.�:���".�"��?�?�#�=�=��*�*��������{�{��Y�Y��Y�Y��j�j�!�.�.����!�.�.�!�.�.�!�L�$�'�.:�124�125�<�?�?�+�;-r�c�V�0n[5nURH@up4nU[:XaUSRX'M#U[:XdM/URU5 MB UVs1sHnX1;dM126XiM nnUR
5Vs1sHnXv;dM127UiM nnU$s snfs snf)zUReturn the set of interrupt ids that are pending without corresponding resume values.r)�setr�r4r�r9�addr)	r��pending_interrupts�pending_resumesr�128write_typer}�resumed_interrupt_ids�interrupt_id�hanging_interruptss	         r��_pending_interrupts�PregelLoop._pending_interruptss���.0��%(�E��*.�*H�*H�&�G���Y�&�.3�A�h�k�k�"�+��v�%��#�#�G�,�+I�+�!129�*���,�
(��'�*�	�!130�!3� 9� 9� ;�(131� ;���8�
� ;�	�(132�"�!��!133��(134s�!	B!�.B!�135	B&�B&c��URR[05n[UR[1365n[
URS5=(a� [
UR[URSL=(dm U=(dd UR(+=(aL URRS05RS5URRS[5:H55nUR=(a� UR=(a- UR[S5UR[05;=(dQ U=(a& [[137UR5R SL=(d UR[S5(+nU(a0UR"Vs/sHowS[$:wdMUPM snUlU(GaY[[138UR5R =nb�UR&(d[)S5e[U[*5=(a [-SU55=n	(aX�R[[.'O([1UR355S:�a[)S	5e[5[65n139[9[[140UR5S1419H-up�n
U[$:Xa	W	(aMX�R;X�45 M/ U142(dW	(d[=S5eU143R?5Hup�URAX�5 M UR"Vs/sHowS[B:XdMUSSPM sn=n(a\[EURURF[IS
[JU/5/URLURN5nUbURQU5 U(GaURSRS[T05 URFHCnUURS;dMURSUnUURS[TU'ME U(abURRS5S;aCUR"Vs/sHowS[T:wdMUPM snUlURWSS05 URYS[ZUR\SURF5 GO�[_[aXR55=n(Ga�[cURUR"URdURFURfURURhURjSSSSUS9
n[EURURF/URm5Q[IS
[JU/5PURLURN5nURnbgUHaup�[URpRU5[r5(dM5URnR;URh[BX�45 Mc URtS:wadUVV
s/sH8up�[URpRU5[r5(dM5X�4PM: nnn
U(aURA[BU5 X l;URWSS05 O[U;a[=SU35eUR(d�SnU(aqURSnURRS5S;a8URx(a'URx[R[zU5n[}U5n[UR[U[�U05UlSUlAU(aUR�S5 U$s snfs snfs snfs sn
nf)N�channel_versions�metadatar�r�Fr{z3Cannot use Command(resume=...) without checkpointerc3�8# �UHn[U5v� M g7fr�)rf)r�rWs  r�r��$PregelLoop._first.<locals>.<genexpr>{s���E�f��1�!�4�4�f�r�z�When there are multiple pending interrupts, you must specify the interrupt id when resuming. Docs: https://docs.langchain.com/oss/python/langgraph/add-human-in-the-loop#resume-multiple-interrupts-with-one-invocation.)�cmdzReceived empty Command inputrr��
versions_seenrE)�update�forkr{rT)r"r�r�r�r�rr�zReceived no input for r��pendingr�)Cr�r�r%r�r�rpr�r�r+r�r�r>r�r(r'rr�r�r9r�r��dictr144r*�lenrqrrr_r�rFrrr7rMr�rLr3r�r�rz�145setdefaultr4rIr&rbr�rr`rPr�r�r�r�rr�r�rCr�r�r�r&r;r$r)r�r�)r�r�r��configurable�input_is_command�is_resuming�is_time_travelingr�r��
resume_is_maprrLrr�ws�null_writes�null_updated_channelsrW�version�input_writes�
discard_tasks�delta_input�replay_state�replay_checkpoint_ids                        r��_first�PregelLoop._first;s����{�{���t�R�0��%�d�j�j�'�:���4�?�?�+=�>�?�146�D����#��147�148�d�"��#�����&�G������149�B�7�;�;�H�E��/�/�3�3�H�g�F�G�
	
�E150��"!�-�-�151����C� �$�$�%=�r�B��#�#�$=�r�B�C�
�"�R�d�7�D�J�J�&?�&F�&F�d�&R�@� �#�#�$7��?��	�&��9�9�.�9�a�q�T�V�^��9�.�D�*�152��w��153�154�3�:�:�:��G��(�(�&�M���155�v�t�,�F��E�f�E�E��=��@F�K�K��%�&;�<��4�3�3�5�6��:�*�Z���156?J�$�>O�F�(�T�'�4�:�:�-F�G�	����V��
�
��K�&�&��v�.�H��-�%�&D�E�E�!�<�<�>�������(�*� �9�9�157�9�a�q�T�\�=Q�E�A�a�b�E�9�158�159�;�160�%1�����
�
�!�"�e�[�"�=�>��2�2��%�%�%�!� �+� �'�'�(=�>���O�O�O�,�7�7�	�2�F��]�]������(:�;�;�"�o�o�.@�A�!�D�G�EL�D�O�O�O�4�Y�?��B�#�!�T�%=�%=�%A�%A�(�%K�T�&� $�=�=�2�=�!�1���AR�A�=�2��.��$�$�h��%7�8��J�J��+�T�-=�-=�t�T�]�]�
�#�9�Z���#D�E�
E�\�
E�.�����.�.��161�162��
�
��������	�	��	�	�"��!��!1��M�  ,�����
�
��"�)�)�+��$�R���b�A���2�2��%�%�	 ��"�&�&�2�(�D�A�!�$�*�*�.�.��"3�\�B�B��/�/�6�6��	�	�<�QR�7V�W�)�163���&�(�!-�� ,���!�$�*�*�.�.��"3�\�B��Q�F� ,���164��O�O�L�+�>�$4�!�� � �(�G�!4�5�
 ��
4�!�$:�:�,�"G�H�H��~�~� 04�L� �'+���t�'<�$��,�,�0�0��:���165�3�3�+/�+F�+F�t�+L�+P�+P�0�2F�,�(� +�+?�@��,����'��+�\���D�K� �����,�,�X�6����a.��F166��F2��fs0�9^4�
^4�167^9�	^9�?^>�^>�4_�_c168��	�XRLnU(aURSUR:XagU(d�[URR	S5=(d 05n0nUR169=(d170 [
5nURR5HDupg[U[5(dMUR	US5up�U	S-
n	Xe;aUS-
nX�4XF'MF URUS'UR[R	[05US'XlO-[URR	S5=(d 05nURSL=(a U=(d UR S:gn171U172(a[#URU5O	[
5n[%URU173(aUROSURU(aURSOSUR174U175(aUR&OSUS9UlUHnSXL'M	 UR5VV
s0sHup�U
S:wdM
X�_M nnn
U(aX�RS'OSUR;a
URS	[(URS	;a�[+S176URR-555(afURS	[(Vs/sH/n[U[.5(a[1X�R5OUPM1 nnUURS	[('U177(Ga�URGb|[2UR4[;a+UR4[[2(aUR4OSUl0UR4E[0UR4[E[8UR[R	[8S50E0EUlURSR;5n[=UR>U5nUUlURAUR[CUS
S5UR4[EUR5URU5Ul#0UR4E[0UR4[E[2URS0E0EUlU(dU=RS-
slggs sn
nfs snf)Nr��counters_since_delta_snapshot)rrr{r��parentsr)r�r��get_next_version�channels_to_snapshot�channel_valuesc3�B# �UHn[U[5v� M g7fr�r�r�s  r�r��-PregelLoop._put_checkpoint.<locals>.<genexpr>os���>178�?U�G�J�w��/�/�?U�rr�rt�_put_checkpoint_fut)$r�r�r�r}r�r�rir�rr�rCr�r�r%r'r�r�rZrYr�r:r
rrurSr&r�r�r(�copyrer�r��getattrrXr�)r�ru�exiting�
prev_counters�new_counters�updated�ch_namerM�ur��
do_checkpointr�rWr�non_zeror}�sanitized_tasksrt�new_versionss                   r�rI�PregelLoop._put_checkpoints~���6�6�6���t���t�,��0H�0H�H�� � ��(�(�,�,�-L�M�S�QS��M�8:�L��+�+�4�s�u�G�#�}�}�2�2�4���!�"�l�3�3��$�(�(��&�9����Q����%���F�A�)*���%� 5� $�y�y�H�V��"&�+�+�d�"3�"7�"7�8Q�SU�"V�H�Y��'/�$���(�(�,�,�-L�M�S�QS��L��=�=�T�I�179��0�t���&�0�	��
'�t�}�}�l�C���	�180,��O�O�*�D�M�M���I�I�(/�t���t�$�T�!�2�2��"�?�?��!5�181182���&�A�$�L�O�&�%1�%7�%7�%9�I�%9�T�Q�Q�&�[�D�A�D�%9��I��HP�$�$�%D�E�
,��0H�0H�
H��(�(�)H�I��D�O�O�$4�5�5�#�>183�?C�}�}�?S�?S�?U�>184�;185�;186�"�_�_�-=�>�u�E�	�F�E��e�T�*�*�2�%���G���F�	
��8G�D�O�O�,�-�e�4��T�B�B�N�,�t�/E�/E�d�/K�K��*�*�4�0�1I�J��&�&��	
�'�&��(�(�&����,�,�T�2��,�d�k�k�$�.?�.C�.C�0�"�/��&�D�"� $���/A�B�G�G�I��3��1�1�3C��L�1A�D�-�187(,�{�{��5�5���3�T�:��&�&�����0��(�(��
(�D�$�&��(�(�&����,�,�T�2��,�d�o�o�d�.C��&�D�"���I�I��N�I���wJ��s�7S�S�!6S%c188�h�UR(a'URbURb
URcg[	UR189R
S5=(d 05n[URU5nURVVVVs/sHup4pVXR;dM
X4XV4PM nnnnnU(dgUR(a
URnO�[5n	URU	S'[R"[R 5R#5U	S'[%UR[&S05n190[%UR[&U	S05nUR)UR[+USS5U191U	SS005UlX�l0nUH)up4pVUR1X44/5R3XV45 M+ [%U[4UR6[8R
[4S5[&U[8[&05nUR;5H�uup4n
US	S192U3nUR<(a UR)URUU
US5nOUR)URUU
U5nUR>cMnUR>R3U5 M� gs snnnnf)u5Stage stub + accumulated delta writes so final_checkpoint's put193waits on them (visibility invariant: both must be durable before194final_checkpoint becomes visible to readers).195 196Stub is created lazily — only when no persisted parent exists AND at197least one delta channel has writes that won't be snapshotted.198Nr�r��tsr�r������r��08dr) r�r�r�r�r}r�r�rZr�r�r�r[r�r�nowr�utc�	isoformatr$r&r�r�r�r�rr�r(r�r%rr�r�)r��countersr�r�rLrMrr|�
anchor_config�stub_cp�stub_put_config�grouped�anchor_write_config�entries�	synth_tidrs                r��_put_exit_delta_writes�!PregelLoop._put_exit_delta_writes�s����'�'�� � �(��4�4�<��+�+�3����$�$�(�(�)H�I�O�R�199�� :�$�-�-��R��'+�&=�&=�200�&=�"��B��-�
�T���&=�	�201�202���%�%�!�;�;�M�&�(�G� �4�4�G�D�M�$�L�L����6�@�@�B�G�D�M�0��/�/�)�4�0��O�203/��/�/�)�7�4�=�9��M�(,�{�{��5�5���3�T�:�������
(�D�$�&3�"�AC�� '��D�r�����{�B�/�6�6��w�?�!(�0��(�$�+�+�d�*;�*?�*?�,�b�+�)�-��*=�>V�*W�	
�204��%,�M�M�O� �K�T����*�A�c�U�+�I��=�=��k�k��0�0�'�������k�k��0�0�'���	���%�%�1��&�&�-�-�c�2�%%4��i205s�J,206�J,207c��^	�URS:XapUR(a$Uc![SUR55(a;UR	5 URUR5 UR5 [U[5(Ga+UR(GdUnUR(a[URS5OSnURSUS9 [US5(GaGUR(Ga5[SUR R#555(Ga[%UR&UR(UR R#5UR*UR,5nUR/[UR0[25(a
UR04OUR05(djUR5S	[6UR0UR R#5VVs/sHowR8Ho�PM M snnUR(5 UR(aURS(d8UR(aURSOSm	UR5S208U	4Sj5 [;UR(UR05UlgUc&[;UR(UR05Ulggs snnf)
Nrc3�4# �UHn[U;v� M g7fr�)r5)r��parts  r�r��1PregelLoop._suppress_interrupt.<locals>.<genexpr>s���E�2D�$�6��%�2D�s�rr�r�r�r�c3�8# �UHoRv� M g7fr�)r)r�rs  r�r�r� s���D�0C����0C�r�r�updatesc�(>�[[T0/5$r�)�iterr4)�interrupt_payloads�r��<lambda>�0PregelLoop._suppress_interrupt.<locals>.<lambda>:s���D�9�.?�"@�!A�Br�T)r�r�r209r�r�rIr�rr�rG�argsr�r�rr�r
r�rrMr�r�r�r�rGr�r�r&rbrrcr�)210r��exc_type�	exc_value�	tracebackr�r�r�rKr�r�s211         @r��_suppress_interrupt�PregelLoop._suppress_interrupts.����?�?�f�$�����$��E�$�2D�2D�E�E�E��'�'�)�� � ��!9�!9�:��$�$�&��i��0�0�����!�I�5>�^�^��y�~�~�a�0�1��J��,�,�[�Z�,�P���g�&�&��2�2�2��D��212�213�0A�0A�0C�D�D�D�#/��O�O��M�M��J�J�%�%�'��6�6��)�)�$� �(�2�2�!�$�"2�"2�C�8�8��%�%�'��)�)���214�J�J� �)��(�(�$(�J�J�$5�$5�$7�J�$7�q���A����$7�J��
�
���>�>�����):�9B���I�N�N�1�$5�R�!��215�216��B��217(��
�
�t�7G�7G�H�D�K��
�
�'��
�
�t�7G�7G�H�D�K���Ks�K-c218�L�URcgUS;=(a SURR;nXRR;aU(dgU"U0UD6H�nXRR;aURURX45 U(dMBURURSUS:XaURS-219OUR[R220"[R5R5US:XaSO	SU;aSOSUS	.45 M� g)221N)r<r��debugr<r{r��result�task_resultr)r��	timestamp�type�payload)	r~r|r�r�rr�rr�r�)r�r�rr��kwargs�debug_remaprs       r�r&�PregelLoop._emitDs����;�;����6�6�W�7�d�k�k�FW�FW�;W���{�{�(�(�(�����(��(�A��{�{�(�(�(����T�/�/��9�:��{�����*�*�� $�}�4�%)�I�I��M�!%���)1���h�l�l�)C�)M�)M�)O�#�}�4�%1� (�1�}�"/�!'�'(����)r�r>c�^^�URRU5=n(Ga�URb)[URRS[5;agUSS[222:XGaURS[:XaURSSLag[223[SU550/mUR(aURRO/nSU;aURSU4Sj5 SU;au[URUR5m[T[ 5(a*TS[224T[225'URSU4S	j5 OLURSU4S226j5 O5USS[":wa%URS[$URXB4/U5 U(d$URS[&XB4UR(5 ggg)N�tagsr�����Tc3�# �UHAnUS[:XdM[US[5(aUSOUS4HnUv� M	 MC g7f)rr{N)r4r�r	)r�r�rs   r�r��+PregelLoop.output_writes.<locals>.<genexpr>xsZ���)�%+�� ��t�y�0��/9��1��x�.H�.H�a��d�q�QR�t�g�&U���'V��%+�s227�A�4Ar�c�>�[T5$r��r�r�s�r�r��*PregelLoop.output_writes.<locals>.<lambda>�s228���$�z�2Br�rc�>�[T/5$r�r�)�current_valuess�r�r�r��s
���T�>�:J�5Kr�c�>�[T5$r�r�r�s�r�r�r��s229���T�*�5Er�r�)r�r�r�rEr=r4rr8r�r~r|r&rcr�r�r�r}r1rarhr�)r�rrr?r�stream_modesr�r�s      @@r�r�PregelLoop.output_writeshs�����:�:�>�>�'�*�*�4�*��{�{�&�:�������	�:�,���a�y��|�y�(��9�9�Q�<�4�'�D�I�I�b�M�T�,A��"�5�)�%+�)�$��	�230�59�K�K�t�{�{�0�0�R����,��J�J�y�*B�C��|�+�%2�4�=�=�$�BR�BR�%S�N�!�.�$�7�7�4>�q�M�)�4L��y�1��231�232�8�-K�L��233�234�8�-E�F�����1���&��235�236��&��$�$��^�$�����237�238��*��N��$�$�	��S+r�)&r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r~r�r�r�r�)*r�r�r~r�r�rr�r�r��BaseCache | Noner�r�r�r�r�r�r�r�r�r�r�r�r��Mapping[str, Sequence[str]]r�rqr�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�)r�zLiteral['resume', 'interrupt']r�ztuple[Interrupt, ...]r�r�)r�zGraphLifecycleEvent | None�rr�r�WritesTr�r�)r�r�r��rrsr(r�r)zCall | Noner��PregelExecutableTask | None�r2rsr3�
BaseExceptionr�r�)r�r��r�zSequence[PregelExecutableTask])r�z"Mapping[str, PregelExecutableTask]r�r�)r�zset[str])r�r�r�r�r�r�)rurr�r��r�ztype[BaseException] | Noner�zBaseException | Noner�zTracebackType | Noner�zbool | None)239r�rvrzCallable[P, Iterator[Any]]r�zP.argsr�zP.kwargsr�r�)rr�rr�r?r�r�r�)"�__name__�240__module__�__qualname__�__firstlineno__�__annotations__r�r�r�r�r�r�r=r�r�r�rrr,r4r7rBrNrQrTr'rArqr�rIr�r�r&r�__static_attributes__r�r�r�r�r��s������!�!�241
�I�242
�I���$�$�,�,�#�#�7�7�#�#�$�$�$�$����O�
<�<�(�(�)�)���'�'�$�$�#1�1�Q�Q�/3�3�243	��=�<��N�'�'�+/��'�.�37��/�6�BF��>�E�!/�.�#(��4�'�
 � �����"�"�%�%�+�+�1�1�">�>�1�1�
����*�*�*.�F�'�.�(,��o�,�7�7�$(�(�(09�09�CG�BF�.0�+/�.3�-dQ��dQ�&�	dQ�244�dQ� �
dQ� �dQ�1�dQ�(�dQ�<�dQ�(�dQ�)�dQ�)�dQ�6�dQ��dQ� -�!dQ�".�#dQ�$A�%dQ�&@�'dQ�(,�)dQ�*)�+dQ�,(,�-dQ�.245�/dQ�T-/�	 &�,� &�*�	 &�246247� &�D6�248U0�n&�ROS�%�(�%�58�%�@K�%�	$�%�N"�/�"�8E�"�	$�"�249"�/�"�8E�"�	$�"�250R�h&9�P"�"�251
+�7�
+�	
�
+�A;�F"�<b �0�b �DS�b �	�b �HG�R[3�z=I�,�=I�(�=I�(�	=I�252253�=I�~"��"�+�"��	"�254�"�255�
"�J@E�2��2�$+�2�8<�2�	
�2�2r�r�c�2^�\rSrSrS\\\\\SSSSS.256SU4SjjjrSSjrSSjrSSU4S	jjjrSS257jr	SU4Sjjr258SSjrSS
jrSr
U=r$)�SyncPregelLoopi�Nr�F)259r�r�r�r�r�r�r�r�r�r�c�b>�[TU]UUUUUUUUUUUUU
UUU	UUU260US9 [5UlU(aXURUlURUl[UR5RRS5SLUlg[UlSUl
SUlSUlg�N)r~r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r��	task_pathF)�superr�r
�stackr�r�rr�r�261parametersr�r�rOr�)r�r�r~r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r��	__class__s                     �r�r��SyncPregelLoop.__init__�s����0	������%�����!�#�#�+�-��1�-�%�%�!�*G�)	�	262�,�[��263��1=�1N�1N�D�.�+7�+B�+B�D�(��,�1�1�2�=�=�A�A�+�N���
�:�2642;�D�.�48�D�1�+/�D�(�=B�D�:r�c�d�UR(a2UR/so`l[RRU5 UbUR	5 [[UR5RX#XE5 g![[UR5RX#XE5 f=fr�)	r��265concurrent�futures�waitr�rrr��put�r��prevr�r�rur��futss       r�r��/SyncPregelLoop._checkpointer_put_after_previous�s����!�!�+/�+A�+A�2�(�D�(����#�#�D�)�	������
��$�d�&7�&7�8�<�<��H�
��D�$�d�&7�&7�8�<�<��H�
�s�B�,B/c��URcg/nURR5Vs0sHVnUR(dMUR(aM)URR266URR4U_MX sn=n(akURR[U55R5H5upEX4nURRU5 URU5 M7 U$s snf)Nr�)r�r�r�	cache_keyr�ns�keyr�r�rrr��r��matchedrKr?rrrs       r�rQ�"SyncPregelLoop.match_cached_writes�s����:�:���.0���Z�Z�&�&�(�267�(���{�{�
1�#$�8�8�
1�Q�[�[�^�^�Q�[�[�_�_�-�q�0�(�268�269�6�270�271 $�z�z�~�~�e�F�m�<�B�B�D����{�����"�"�6�*����t�$� E����272s�D�D�1Dc�>�[TU]XU5=n(a<UR5H(nURURUR273SS9 M* U$�NTr>)r�r,rQrr�r�r�rr(r)r+r�s     �r�r,�SyncPregelLoop.accept_push�sQ����W�(��$�?�?�6�?��0�0�2���"�"�4�7�7�D�K�K��"�E�3��
r�c�&�URURRnU(dgUR(a2UR/so@l[R274R
U5 [U4UUURURURURURURURURURUR UR"UR$UR&S.6nUcgXPR(UR*'UR,(dUR/UR*U05 UR15H(nUR3UR*UR4SS9 M* U$�Nr\Tr>)r�r`rar�r�r�r�rQr�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r'rQrr�r�r2r3rerrfrs       r�r4�%SyncPregelLoop.schedule_error_handlersC���z�z�+�"2�"2�3�F�F�����)�)�37�3Q�3Q�SU�0�D�0����#�#�D�)�6��275�*������9�9��j�j��]�]��L�L��%�%��������*�*��*�*��L�L��*�*��*�*�!276��$���&2�277�278�<�?�?�#�� � ��3�3�\�_�_�l�4S�T��,�,�.�D����t�w�w����D��A�/��r�c�>�[TU]X5 U(aURb[US5(dgURRU5nUb
URcgURURRURRURR4URURR405 g)r�Nr�)
r�rr�rr�r�rr�rirrr�ttl�r�rrrr�s    �r�r�SyncPregelLoop.put_writes)s����
���7�+�����+�7�4��3I�3I���z�z�~�~�g�&���<�4�>�>�1������J�J�N�N����"�"�D�N�N�$6�$6�7��K�K��N�N�&�&�:�
�	279r�c�r�[5UlUR(dSnGOUR[R[5(a&URRUR5nO�UR[R[5=n(atURUR[R[S5URUR5nUR[R[S5 O%URRUR5nUSLUlUc$[UR[!5SS0S/5nO(UR"bUR#UR$5 0UREURE[[S0URR[05EURR[05E0EUlURUlUR(UlUR$SUlUR$UlUR.UlUR2b/UR2VVVs/sHup4n[5U5XE4PM snnnO/Ul/Ul/UlUR<S:XaURb/OSUlUR@RC[EUR55Ul#[IURJUR$URURS9uUl&Ul'UR@RQURR5 SUl*UR0SS-Ul+URVURS	-S-Ul,UR$S280R[5Ul.UR_UR`UR$RS5(a$[cUR$RS55OSS9Ul2U$s snnnf�
Nr�r�r�r�r)�saverr�r�r{�recursion_limitrtr�)r�r�)3rr�r�r�r%r�r&�	get_tupler�r)�get_checkpointr(rJr+r�rr[r�r�r��
parent_configr�r�rur�r r�r�r�r�r�r�r��
enter_contextr]r�rWr�r�r��pushr�r�r�r�r�r�r�r�rir��r��savedr�rLrWrs      r��	__enter__�SyncPregelLoop.__enter__=s���',�w��$�� � ��E�
�
#�
#�D�
)�
-�
-�.F�
G�
G��%�%�/�/��0F�0F�G�E�!�[�[��.�2�2�3J�K�
K�\�
K�!�/�/����D�!�%�%�&>��C��!�!��&�&��E�
�K�K���!�!�"5�t�<��%�%�/�/��0F�0F�G�E�281&+�$�%6��"��=�#��&�&�(8�(:�V�R�L�$�PR��E��
%�
%�
1��$�$�U�%5�%5�6�"282��$�$�"283��l�l�"284�
�(�"���(�(�,�,�T�2�6���,�,�"�"�4��,��"285���+/�*@�*@��'�&+�&9�&9��#�#(�#3�#3�D�#9�� ��*�*���#(�>�>�� ��#�#�/�05�/C�/C�D�/C�)�#�!�c�#�h��
�/C�D��	
�&�286"$���)+��&��/�/�V�+��0A�0A�0M�B�SW�	
���j�j�.�.�/A�$�+�+�/N�O���&>��J�J��O�O��#�#��)�)�	'287�#��
�t�|�	
�288�289����0�0�1�����,�,�V�4�q�8��	��I�I����,=� >�>��B��	�,0�O�O�<N�,O�,T�,T�,V��)� $���������"�"�#5�6�6�!����!4�!4�5G�!H�I��	!,�!290������9
Es�6P2c�:�URRXU5$r�)r��__exit__)r�r�r�r�s    r�r#�SyncPregelLoop.__exit__�s���z�z�"�"�8�	�B�Br��r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�)*r�r�r~r�r�rr�r�r�r�r�r�r�r�r�r�r�r�r�rqr�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�)r�z concurrent.futures.Future | Noner�rr�rrurr�rr�rr�r�r�r�r��r�r#r�)r�r�r�r�r=r�r�rQr,r4rr r#r��
__classcell__�r�s@r�r�r��s����DH�/8�09�*3�+4�+4�BF�.0�+/�.3�-:C��:C�&�	:C�291�:C� �
:C� �:C�1�:C�(�:C�<�:C�6�:C��:C�A�:C�-�:C�.�:C� (�!:C�")�#:C�$)�%:C�&@�':C�(,�):C�*)�+:C�,(,�-:C�.292�/:C�:C�x�.�����	�293%��&�
�294��&
� OS��(��58��@K��	$���#�/�#�8E�#�	$�#�J295�(P�dC�,�C�(�C�(�	C�296297�C�Cr�r�c�2^�\rSrSr\\S\\\SSSSS.298SU4SjjjrSSjrSSjrSSU4S	jjjrSS299jr	SU4Sjjr300SSjrSS
jrSr
U=r$)�AsyncPregelLoopi�Nr�F)301r�r�r�r�r�r�r�r�r�r�c�b>�[TU]UUUUUUUUUUUUUU
UU	UUU302US9 [5UlU(aXURUlURUl[UR5RRS5SLUlg[UlSUl
SUlSUlgr�)r�r�rr�r�r��aput_writesr�rr�r�r�rOr�)r�r�r~r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�s                     �r�r��AsyncPregelLoop.__init__�s����0	������%�����!�#�#�+�-��1�-�%�%�!�*G�)	�	303�,$�%��304��1=�1N�1N�D�.�+7�+C�+C�D�(��,�2�2�3�>�>�B�B�;�O���
�:�3052;�D�.�48�D�1�+/�D�(�=B�D�:r�c��# �UR(a.UR/so`l[R"U6IShv�N Ub306UIShv�N [[UR3075R
X#XE5IShv�N gNEN9N	![[UR3085R
X#XE5IShv�N f=f7fr�)r��asyncio�gatherrrr��aputr�s       r�r��0AsyncPregelLoop._checkpointer_put_after_previous�s�����!�!�+/�+A�+A�2�(�D�(��.�.�$�'�'�'�	����309�310��*�D�,=�,=�>�C�C��H��
�
�
(��
��$�*�D�,=�,=�>�C�C��H��
�
�sW�;C�B�C�B	�B�B	�-C�=B�>C�B	�C�	.B>�7B:�8B>�>Cc��*# �URc/$/nURR5Vs0sHVnUR(dMUR(aM)URR311URR4U_MX sn=n(asURR[U55IShv�NR5H5upEX4nURRU5 URU5 M7 U$s snfNR7fr�)r�r�rrrrr�agetr�rrr�rs       r�rT�$AsyncPregelLoop.amatch_cached_writes�s�����:�:���I�.0���Z�Z�&�&�(�312�(���{�{�
1�#$�8�8�
1�Q�[�[�^�^�Q�[�[�_�_�-�q�0�(�313�314�6�315�316'+�j�j�o�o�e�F�m�&D� D�K�K�M����{�����"�"�6�*����t�$� N����317�318!E�s)�.D�D�	D�1D�
1D�>D�?ADc���># �[TU]XU5=n(aDUR5IShv�NH(nURURUR319SS9 M* U$N27fr320)r�r,rTrr�rrs     �r��aaccept_push�AsyncPregelLoop.aaccept_push�s_�����W�(��$�?�?�6�?�"�7�7�9�9�9���"�"�4�7�7�D�K�K��"�E�:��
�:�s�+A#�A!�3A#c��@# �URURRnU(dgUR(a.UR/so@l[R321"U6IShv�N [
U4UUURURURURURURURURURURUR UR"UR$S.6nUcgXPR&UR('UR*(dUR-UR(U05 UR/5IShv�NH(nUR1UR(UR2SS9 M* U$GN1N57fr)r�r`rar�r/r0rQr�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r'rTrrrs       r�r7�'AsyncPregelLoop.aschedule_error_handlersT����z�z�+�"2�"2�3�F�F�����)�)�37�3Q�3Q�SU�0�D�0��.�.�$�'�'�'�6��322�*������9�9��j�j��]�]��L�L��%�%��������*�*��*�*��L�L��*�*��*�*�!323��$���&2�324�325�<�?�?�#�� � ��3�3�\�_�_�l�4S�T��3�3�5�5�5�D����t�w�w����D��A�6���5
(�06�s%�A&F�(F�)C=F�&F�'3F�Fc��>�[TU]X5 U(aURb[US5(dgURRU5nUb
URcgUSS[[4;agURURRURRURR4URURR405 g)r�Nr�r)r�rr�rr�r�rr4r1r��asetrrrrrs    �r�r�AsyncPregelLoop.put_writes's����
���7�+�����+�7�4��3I�3I���z�z�~�~�g�&���<�4�>�>�1���!�9�Q�<�I�u�-�-������J�J�O�O����"�"�D�N�N�$6�$6�7��K�K��N�N�&�&�:�
�	326r�c���# �[5UlUR(dSnGO/UR[R[5(a.URRUR5IShv�NnO�UR[R[5=n(a|URUR[R[S5URUR5IShv�NnUR[R[S5 O-URRUR5IShv�NnUSLUlUc$[UR[!5SS0S/5nO(UR"bUR#UR$5 0UREURE[[S0URR[05EURR[05E0EUlURUlUR(UlUR$SUlUR$UlUR.UlUR2b/UR2VVVs/sHup4n[5U5XE4PM snnnO/Ul/Ul/UlUR<S:XaURb/OSUlUR@RC[EUR55IShv�NUl#[IURJUR$URURS9IShv�NuUl&Ul'UR@RQURR5 SUl*UR0SS-Ul+URVURS	-S-Ul,UR$S327R[5Ul.UR_UR`UR$RS5(a$[cUR$RS55OSS9Ul2U$GN�GNcGNs snnnfGNQGN7fr)3rr�r�r�r%r�r&�328aget_tupler�r)�aget_checkpointr(rJr+r�rr[r�r�r�rr�r�rur�r r�r�r�r�r�r�r��enter_async_contextr\r�rVr�r�r�rr�r�r�r�r�r�r�r�rir�rs      r��329__aenter__�AsyncPregelLoop.__aenter__>s����',�w��$�� � ��E�
�
#�
#�D�
)�
-�
-�.F�
G�
G��+�+�6�6�t�7M�7M�N�N�E�!�[�[��.�2�2�3J�K�
K�\�
K�'�6�6����D�!�%�%�&>��C��!�!��&�&���E�
�K�K���!�!�"5�t�<��+�+�6�6�t�7M�7M�N�N�E�330&+�$�%6��"��=�#��&�&�(8�(:�V�R�L�$�PR��E��
%�
%�
1��$�$�U�%5�%5�6�"331��$�$�"332��l�l�"333�
�(�"���(�(�,�,�T�2�6���,�,�"�"�4��,��"334���+/�*@�*@��'�&+�&9�&9��#�#(�#3�#3�D�#9�� ��*�*���#(�>�>�� ��#�#�/�05�/C�/C�D�/C�)�#�!�c�#�h��
�/C�D��	
�&�335"$���)+��&��/�/�V�+��0A�0A�0M�B�SW�	
��!�J�J�:�:�#�D�K�K�0�336�337���-F��J�J��O�O��#�#��)�)�	-338�'339�#��
�t�|�	
�340�341����0�0�1�����,�,�V�4�q�8��	��I�I����,=� >�>��B��	�,0�O�O�<N�,O�,T�,T�,V��)� $���������"�"�#5�6�6�!����!4�!4�5G�!H�I��	!,�!342�����UO�343�O��6
E�344�'345�sl�A8Q2�:Q�;BQ2�<Q�=AQ2�Q"�D>Q2�Q%�*A1Q2�Q,�AQ2�Q/�DQ2�Q2�"Q2�%Q2�/Q2c���# �[R"URRXU55nUIShv�N$N![Ran/UR346QUP7UleSnAff=f7fr�)r/�create_taskr��	__aexit__�CancelledErrorr�)r�r�r�r��	exit_task�es      r�rF�AsyncPregelLoop.__aexit__�si����'�'��J�J� � ��i�@�347�	�	�"�?�"�?���%�%�	�*�q�v�v�)�y�)�A�F���		�s5�1A3�A�>�A�A3�A�A0�A+�+A0�0A3r%)*r�r�r~r�r�rr�r�r�r�r�r�r�r�r�r�r�r�r�rqr�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�)r�zasyncio.Task | Noner�rr�rrurr�rr�rr�r�r�r�r�r&r�)r�r�r�r�r=r�r�rTr7r7rrBrFr�r'r(s@r�r*r*�s����09�09�CG�*3�+4�+4�BF�.0�+/�.3�-:C��:C�&�	:C�348�:C� �
:C� �:C�1�:C�(�:C�<�:C�6�:C��:C�-�:C�.�:C�A�:C� (�!:C�")�#:C�$)�%:C�&@�':C�(,�):C�*)�+:C�,(,�-:C�.349�/:C�:C�x�!�����	�350%��&�
�351��*
� OS��(��58��@K��	$���#�/�#�8E�#�	$�#�J352�.R�h�,��(��(�	�353354��r�r*)rrkr�rk)��355__future__rr/r#�concurrent.futuresr��collectionsrr�collections.abcrrrr	�356contextlibr357rrr
rr�inspectr�typesr�typingrrrr�langchain_core.callbacksrr�langchain_core.runnablesr�langgraph.cache.baser�langgraph.checkpoint.baserrrrrrr �langgraph.store.baser!�typing_extensionsr"r#�langgraph._internal._configr$�langgraph._internal._constantsr%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9r:�langgraph._internal._replayr;�langgraph._internal._scratchpadr<�langgraph._internal._typingr=r>�langgraph.callbacksr?r@rA�langgraph.channels.baserB�langgraph.channels.deltarC�"langgraph.channels.untracked_valuerD�langgraph.constantsrE�langgraph.errorsrFrG�langgraph.managed.baserHrI�langgraph.pregel._algorJrKrLrMrNrOrPrQrRrSrTrU�langgraph.pregel._checkpointrVrWrXrYrZr[�langgraph.pregel._executorr\r]r^�langgraph.pregel._ior_r`rarbrc�langgraph.pregel._readrd�langgraph.pregel._utilsrerf�langgraph.pregel.debugrgrhri�langgraph.pregel.protocolrjrk�langgraph.runtimerlrm�langgraph.typesrnrorprqrrrsrtrurvrwrxr�r�r�r�r�r�r*r�r�r��<module>rosf��"����*�A�A���(�����M�3�*����+�-�:�������04�<�:���3580�1�=�*���
�
�
�
�����359��.�S���360B�1�361�362�363��C�L��
�c�N���5��c��?�364#��Q���D(yC�Z�!7�yC�xI�j�"=�Ir�
codekingpro/portable-devtools · Team Ai