Team Ai
Datasetpublic

codekingpro/portable-devtools

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

2��j�"�3��SSKJr SSKJrJrJrJr SSKJr SSK	J4r5 SSKJr SSK
Jr SSKJrJr SSKJr SS	KJrJrJrJrJrJrJr SS6KJr SSKJr SSK J!r! SS
K"J#r# SSK$J%r%J&r&J'r'J(r(J)r)J*r* \"S5r+S$Sjr,S%Sjr-S&Sjr.S'Sjr/S(Sjr0S)Sjr1S*Sjr2SSSSSSSSSS .	r3S+S!jr4S,S"jr5g#)-�)�annotations)�Iterable�Iterator�Mapping�Sequence��asdict)�Any)�UUID)�RunnableConfig)�CheckpointMetadata�PendingWrite)�patch_checkpoint_map)�CONF�CONFIG_KEY_CHECKPOINT_NS�ERROR�	INTERRUPT�NS_END�NS_SEP�RETURN)�MISSING)�BaseChannel)�7TAG_HIDDEN)�
read_channels)�CheckpointPayload�PregelExecutableTask�8PregelTask�
StateSnapshot�TaskPayload�TaskResultPayloadz$6ba7b831-9dad-11d1-80b4-00c04fd430c8c#��# �UHgnURb&[URRS/5;aM6URURUR9URS.v� Mi g7f)z,Produce "task" events for stream_mode=debug.N�tags)�id�name�input�triggers)�configr�getr#r$r%r&)�tasks�tasks  �\D:\code\apps\devtools\python\user_packages\Python313\site-packages\langgraph/pregel/debug.py�map_debug_tasksr,%sZ������;�;�"�z�T�[�[�_�_�V�R�5P�'P���'�'��I�I��Z�Z��
�
�	10�	11�	�s�A/A1c�n�[U[5=(a SU;=(a [US[5$)zOReturn True if the payload already wraps multiple writes from the same channel.�$writes)�12isinstance�dict�list)�values r+�is_multiple_channel_writer33s4��	�5�$��	/����	/��u�Y�'��.��c��0nUHNup#URU5nUb1[U5(aUSOU/nURU5 SU0X'MJX1U'MP U$)aBFolds task writes into a result dict and aggregates multiple writes to the same channel.13 14If the channel contains a single write, we record the write in the result dict as `{channel: write}`15If the channel contains multiple writes, we record the writes in the result dict as `{channel: {'$writes': [write1, write2, ...]}}`r.)r(r3�append)�writes�result�channelr2�existing�channel_writess      r+�map_task_result_writesr<<st�� �F� ����:�:�g�&����-�X�6�6���#��Z�
�16
�!�!�%�(�(�.�9�F�O�#�7�O�!��Mr4c#��# �[U[5(aU/OUnUup4URUR[	SU5S5[UVs/sHoUSU;dUS[:XdMUPM sn5UVVs/sHHnUS[:XdM[US[5(aUSOUS/Hn[U5PM MJ snnS.v� gs snfs snnf7f)z3Produce "task_result" events for stream_mode=debug.c3�H# �UHoS[:XdMUSv� M g7f�r�N)r)�.0�ws  r+�	<genexpr>�)map_debug_task_results.<locals>.<genexpr>_s���=�V���t�u�}�t�q��t�V�s�"�"Nrr@)r#r$�errorr8�17interrupts)18r/�strr#r$�nextr<rrrr	)�task_tup�stream_keys�stream_channels_listr*r7rB�vs       r+�map_debug_task_resultsrMSs����$�K��5�5��
�;���L�D��g�g��	�	��=�V�=�t�D�(��Q��1�A�$�*>�">�!�A�$�&�.�Q��Q�19�20�21�����t�y� �
�)��1��x�8�8�a��d�q��t�f�D��
�1�I�E�
��22�
�
��23
R��24�s*�AC#�C�/C�5C#�C�:C�C#c��UcU$SURS05R5VVs0sHupURS5(aMX_M! snn0$s snnf)z,Remove pregel-specific keys from the config.�configurable�	__pregel_)r(�items�25startswith)r'�krLs   r+�rm_pregel_keysrTls_��
�~��
���26�27�>�2�6�<�<�>�28�>����<�<��,�
�A�D�>�29����30s�A�31Ac#��# �U[R[S5n0n	UHon32U33R(dMU34R[35U36R3nU(aU[U3n[SU[S[U00X�R'Mq [[X55[[Xc55[X5UUVs/sHo�RPM sn[XEX�5Vs/sH�nUR(a/URURURURS.O�UR(aJURURUR[SUR 55URS.O>URUR[SUR 55URS.PM� snS.v� g	s snfs snf7f)37z2Produce "checkpoint" events for stream_mode=debug.��	thread_id)r#r$rE�statec3�8# �UHn[U5v� M g7f�Nr�rA�is  r+rC�'map_debug_checkpoint.<locals>.<genexpr>�����#D�|�!�F�1�I�I�|���)r#r$r8rFrXc3�8# �UHn[U5v� M g7frZrr[s  r+rCr]�r^r_)r#r$rFrX)r'�
parent_config�values�metadatarHr)N)rr(r�	subgraphsr$rr#rrTrr�tasks_w_writesrErXr8�tuplerF)
r'�channels�stream_channelsrcr)�pending_writesra�output_keys�	parent_ns�task_statesr*�task_ns�ts
             r+�map_debug_checkpointroys�����t�� � �!9�2�>�I�=?�K����~�~���Y�Y�K��x����y�1���"��F�8�G�9�5�G�
��V�D�\�+�6�(�'�� 38��G�G���$!�!5�f�!G�H�'�(<�]�(U�V���:��!&�'��A����'�.$�E�;�T�-39�,U���w�w��d�d����������	
��x�x�
�d�d�����(�(�#�#D�q�|�|�#D�D������d�d����#�#D�q�|�|�#D�D����	�
�*U�-40�
���41(��42�s�C43G'�G�!G'�1C$G"�G'c
�^�U=(d /n/nUGH�m[U4SjU5[5n[U4SjU5S5n[U4SjU55nUVV	V44s/sH2up�n45UTR:XdMU	[[46[4;dM/X�4PM4 nn	nn47U[LaUnO�[U[5(aMUV	V48s/sHup�X�:XdMX�4PM n
n	n49[U
5nU(aUR[U55OSnOL[U[5(aU/nUV	V50s/sHup�X�;dMX�4PM n
n	n51[U
5nU
(aUO0nU[L=(d [U4SjU55nUR[TRTRTRUUU(aURTR5OSU(aUOS55 GM� [U5$s sn52n	nfs sn53n	fs sn54n	f)zJApply writes / subgraph states to tasks to be returned in a StateSnapshot.c3�j># �UH(upnUTR:XdMU[:XdM$Uv� M* g7frZ)r#r)rA�tid�chan�valr*s    �r+rC�!tasks_w_writes.<locals>.<genexpr>�s5����
�&4�N�C�s��$�'�'�>��&*�f�n���&4�s�3�3�	3c3�h># �UH'upo1TR:XdMU[:XdM#Uv� M) g7frZ)r#r)rArr�n�excr*s    �r+rCru�s'����T�N�[�S�S�T�W�W�n�S��e��S�S�N�s�2�2�	2Nc3�># �UHJupnUTR:XdMU[:XdM$[U[5(aUOU/HnUv� M	 ML g7frZ)r#rr/r)rArrrw�vvrLr*s     �r+rCru�s\���� 55�,�56����d�g�g�~�
�"#�y�.�
�'�r�8�4�4�b�2�$�>��
�?�
�,�s�A�A�+Ac3�x># �UH/oSTR:H=(a US[[4;v� M1 g7fr?)r#rr)rArBr*s  �r+rCru�s4����/57�HV�1�a�D�D�G�G�O�>��!��U�I�,>� >�>��s�7:)rHrrfr#rrrr/rGr<r(�anyr6rr$�path)r)ri�statesrj�out�rtn�58task_error�task_interruptsrrrsrt�task_writes�task_result�filtered_writes�
mapped_writes�59has_writesr*s                @r+rere�s����$�)�r�N��C����
�&4�
�60
�
61���T�N�T��62�63� � 64�,� 65�66��#1�67�"0���3��d�g�g�~�
�"&�u�i��.H�"H�
�T�K�"0�	�68��g���K�
��S�
)�
)�.9��-8�	��D�<O����[�
��3�?�C�M�AN�-�+�+�C��,<�=�TX�K��+�s�+�+�*�m��.9��-8�	��D�<O����[�
��3�?�C�M�+:�-��K���'�69�3�/70�HV�/71�,72�73�	�74�75������	�	��	�	���'-��76�77�4�7�7�#�4�)��t�
�78	79�e�z��:���S80����s*� G481�;G482�G483�G;�G;�(H�7Hz0;30z0;31z0;32z0;33z0;34z0;35z0;36z0;37z1;30)	�black�red�green�yellow�blue�magenta�cyan�white�grayc�"�S[USUS3$)zGet colored text.z[1;3�m�)�
COLOR_MAPPING)�text�colors  r+�get_colored_textr�s��
�m�E�*�+�1�T�F�'�:�:r4c��SUS3$)zGet bolded text.zr��)r�s r+�get_bolded_textr�s��
�T�F�'�"�"r4N)r)�Iterable[PregelExecutableTask]�returnzIterator[TaskPayload])r2r84r��bool)r7zSequence[tuple[str, Any]]r�zdict[str, Any])rIz6tuple[PregelExecutableTask, Sequence[tuple[str, Any]]]rJ�str | Sequence[str]r�zIterator[TaskResultPayload])r'�RunnableConfig | Noner�r�)r'rrgzMapping[str, BaseChannel]rhr�rcr
r)r�rizlist[PendingWrite]rar�rjr�r�zIterator[CheckpointPayload])85r)z+Iterable[PregelTask | PregelExecutableTask]rizlist[PendingWrite] | Noner~z0dict[str, RunnableConfig | StateSnapshot] | Nonerjr�r�ztuple[PregelTask, ...])r�rGr�rGr�rG)r�rGr�rG)6�86__future__r�collections.abcrrrr�dataclassesr	�typingr87�uuidr�langchain_core.runnablesr�langgraph.checkpoint.baser
r�langgraph._internal._configr�langgraph._internal._constantsrrrrrrr�langgraph._internal._typingr�langgraph.channels.baser�langgraph.constantsr�langgraph.pregel._ior�langgraph.typesrrrrrr �TASK_NAMESPACEr,r3r<rMrTrorer�r�r�r�r4r+�<module>r�sK��"�A�A����3�F�<����0�/�*�.����<�=��88���.�D��$��!��289�>��>�'�>�)�>�!�	>�90*�>�'�
>�)�>�%�>�!�>�BF�6�F�-�F�
=�F�%�	F�91�F�T��
�����
��92�
�;�93#r4
codekingpro/portable-devtools · Team Ai