Team Ai
Datasetpublic

codekingpro/portable-devtools

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

2��j���*�SSKJr SSKJrJr SSKJrJrJrJ	r	 SSK3JrJr SSK
JrJrJr SSKJr SSKJr SSKJr SS	KJr \\\\\4/S44r\"S\S9r\"5r\"5r"S
S\5r "SS\5r!"SS\5r"SSjr#g5)�)�annotations)�Callable�Sequence)�Any�6NamedTuple�TypeVar�cast)�Runnable�RunnableConfig)�CONF�CONFIG_KEY_SEND�TASKS)�RunnableCallable)�MISSING)�InvalidUpdateError)�SendN�R)�boundc�P�\rSrSr%S\S'\rS\S'SrS\S'S	rS7\S'Sr	g	)
�ChannelWriteEntry��str�channelr�valueF�bool�	skip_noneNzCallable | None�mapper�)8�__name__�9__module__�__qualname__�__firstlineno__�__annotations__�PASSTHROUGHrrr�__static_attributes__r��]D:\code\apps\devtools\python\user_packages\Python313\site-packages\langgraph/pregel/_write.pyrrs1��
�L�#��E�3��:��I�t��7�"�F�O�"�9r&rc�@�\rSrSr%S\S'\rS\S'SrS\S'S	rg)10�ChannelWriteTupleEntry�%z1Callable[[Any], Sequence[tuple[str, Any]] | None]rrrN�,Sequence[tuple[str, Any, str | None]] | None�staticr)	rr r!r"r#r$rr,r%rr&r'r)r)%s&��=�=�0��E�3��:�;?�F�8�?�8r&r)c��^�\rSrSr%SrS\S'SS.SU4SjjjrSSS.SU4S	jjjjrSS11jrSSjr	\12SSSjj5r\13SS
j5r\14SSj5r
\15SSSjj5rSrU=r$)�ChannelWrite�.z�Implements the logic for sending writes to CONFIG_KEY_SEND.16Can be used as a runnable or as a static method to call imperatively.z7list[ChannelWriteEntry | ChannelWriteTupleEntry | Send]�writesN)�tagsc�>�[TU]URURSUSS9 [	[17[[-[-U5Ul	g)NF)�func�afunc�namer1�trace)18�super�__init__�_write�_awriter	�listrr)rr0)�selfr0r1�	__class__s   �r'r8�ChannelWrite.__init__5sR���	�������,�,����	�	19���"�%;�;�d�B�C�V�20��r&�r5c�x>�U(d&SSRSUR55S3n[TU]
XS9$)Nz
ChannelWrite<�,c3�# �UHIn[U[5(aURO"[U[5(aSOURv� MK g7f)z...N)�21isinstancerrr)�node)�.0�ws  r'�	<genexpr>�(ChannelWrite.get_name.<locals>.<genexpr>Hsl���,p�do�_`��A�GX�9Y�9Y�A�I�I�hr�st�wM�iN�iN�_d�TU�TZ�TZ�-Z�do�s�AA�>r?)�joinr0r7�get_name)r<�suffixr5r=s   �r'rK�ChannelWrite.get_nameFs^����"�3�8�8�,p�dh�do�do�,p�$p�#q�qr�s�D��w����2�2r&c	��URVs/sH�n[U[5(a>UR[La+[UR22XRUR5O?[U[5(a)UR[La[URU5OUPM� nnURUU5 U$s snf�N�23r0rCrrr$rrrr)�do_write�r<�input�config�writer0s     r'r9�ChannelWrite._writeKs������
24�%��	�%�!2�3�3����{�8R�
�e�m�m�U�O�O�U�\�\�R��%�!7�8�8�U�[�[�K�=W�(����e�<��	
�25%�
	�26�	
�
�
���	27����28s�BCc	��# �URVs/sH�n[U[5(a>UR[La+[UR29XRUR5O?[U[5(a)UR[La[URU5OUPM� nnURUU5 U$s snf7frOrPrRs     r'r:�ChannelWrite._awriteZs�������
30�%��	�%�!2�3�3����{�8R�
�e�m�m�U�O�O�U�\�\�R��%�!7�8�8�U�[�[�K�=W�(����e�<��	
�31%�
	�32�	
�
�
���	33����34�s�C	�BC�.C	c��UH�n[U[5(aDUR[:Xa[	S5eUR35[LaU(d[	S5e[U[5(dMsUR36[LdM�U(aM�[	S5e U[[nU"[U55 g)Nz*Cannot write to the reserved channel TASKSz"PASSTHROUGH value must be replaced)rCrrrrrr$r)rr
�_assemble_writes)rTr0�allow_passthroughrFrUs     r'rQ�ChannelWrite.do_writeis����A��!�.�/�/��9�9��%�,�D����7�7�k�)�2C�,�-Q�R�R��!�3�4�4��7�7�k�)�2C�2C�,�-Q�R�R��"�$�<��8��
��v�&�'r&c�^�[U[5=(d [US[5[L$)zFUsed by PregelNode to distinguish between writers and other runnables.�_is_channel_writer)rCr.�getattrr)�runnables r'�	is_writer�ChannelWrite.is_writer�s+��
�x��.�
O��x�!5�w�?�w�N�	37r&c��[U[5(afURVVs/sHCn[U[5(dMUR(dM-URHnUPM ME snn=(d S$[US[5=n(a�U[La�[[[[[-[S-4U5nUVVs/sHupEUPM	 nnnUVVs/sHupWUPM	 nnn[[U5U5V	Vs/sHup�/U	QUP7PM snn	$ggs snnfs snnfs snnfs snn	f)zEUsed to get conditional writes a writer declares for static analysis.Nr^)rCr.r0r)r,r_rr	r�tuplerrr�ziprZ)38r`�entryrFr0�e�_�entries�la�labels�ts39          r'�get_static_writes�ChannelWrite.get_static_writes�s1��40�h��-�-�&�_�_��,�E��e�%;�<��AF�������A��&��,���41�
��x�)=�w�G�
G�V�
G��W�$���U�#4�t�#;�S�4�Z�#G�H�I����*0�0����1���0�*0�1�&���"�&��1�.1�2B�7�2K�V�.T�U�.T�U�Q��!��R��.T�U�U�%�H��
��1��1��Us#�D(�D(�D(�D.�&D4�D:c�4�[RUSU5 U$)z�Used to mark a runnable as a writer, so that it can be detected by is_writer.42Instances of ChannelWrite are automatically marked as writers.43Optionally, a list of declared writes can be passed for static analysis.r^)�object�__setattr__)r`r,s  r'�register_writer�ChannelWrite.register_writer�s��	���8�%9�6�B��r&)r0)r0�;Sequence[ChannelWriteEntry | ChannelWriteTupleEntry | Send]r1zSequence[str] | NonerO)rL�44str | Noner5ru�returnr)rSrrTrrv�None)T)rTrr0rtr[rrvrw)r`r45rvr)r`r46rvr+)r`rr,z<Sequence[tuple[ChannelWriteEntry | Send, str | None]] | Nonervr)rr r!r"�__doc__r#r8rKr9r:�staticmethodrQrarmrrr%�
__classcell__)r=s@r'r.r..s����M�
D�C�=�&*�	47�K�48�#�	49�50�"3��3�3�51
�
��#'�(��(�K�(� �(�52�	(��(�,�53��54��V��V�	5�V��V�*�PT�55��56�L�57�58�59��60r&r.c�>�/nUGHn[U[5(aUR[U45 M2[U[5(a7URUR5=n(aURU5 M|M~[U[5(auUR61bURUR5OURnU[LaM�UR(aUcM�URURU45 GM[SU35e U$)z+Assembles the writes into a list of tuples.zInvalid write entry: )
rCr�appendrr)rr�extendr�62SKIP_WRITErr�63ValueError)r0�tuplesrF�wwrs     r'rZrZ�s���%'�F�
���a�����M�M�5�!�*�%�
��1�
2�
2��X�X�a�g�g�&�&�r�&��
�
�b�!�'�
��,�
-�
-�)*���)=�A�H�H�Q�W�W�%�1�7�7�E��64�"���{�{�u�}���M�M�1�9�9�e�,�-��4�Q�C�8�9�9���Mr&)r0rtrvzlist[tuple[str, Any]])$�65__future__r�collections.abcrr�typingrrrr	�langchain_core.runnablesr66r�langgraph._internal._constantsrr
r�langgraph._internal._runnabler�langgraph._internal._typingr�langgraph.errorsr�langgraph.typesrrdr�	TYPE_SENDrrpr~r$rr)r.rZrr&r'�<module>r�s���"�.���>�G�G�:�/�/� ��h�u�S�#�X��/�0�$�6�7�	��C�x� ��
�X�67��h��:�68�:�9�Z�9�{�#�{�|�G���r&
codekingpro/portable-devtools · Team Ai