codekingpro/portable-devtools
114k
1�
2 ��jw � �� � S SK rS SK JrJr S SKJrJr S SKJrJ r J3r4 S SK J r S SK
Jr S SKJrJr S SKJrJrJrJr S S KJr S5rS rS \S
\\ \4 4S jr S\S\S
\ 4S jr " S S\\ \\\\4 5 r g)� N)�Callable�Sequence)�Any�Generic)� NotRequired�Required�Self)� OVERWRITE)�MISSING)� BaseChannel�Value)�EmptyChannelError� ErrorCode�InvalidUpdateError�create_error_message)� Overwrite)�BinaryOperatorAggregatec � � [ U S5 ( aG U R [ [ 4; a [ U R6 S 5 $ [ U R 5 $ U $ )z=Strips Annotated, Required and NotRequired from a given type.�7__origin__r )�hasattrr r r �
_strip_extras�__args__)�ts �^D:\code\apps\devtools\python\user_packages\Python313\site-packages\langgraph/channels/binop.pyr r sG � ��q�,� � � �<�<�H�k�2� 2� ����A� �/� /� �Q�\�\�*�*� �H� �value�returnc � � [ U [ 5 ( a SU R 4$ [ U [ 5 ( a$ [ U 5 S:X a [8 U ; a SU [9 4$ g)zEInspects the given value and returns (is_overwrite, overwrite_value).T� )FN)�10isinstancer r �dict�lenr11 �r s r �_get_overwriter$ sO � ��%��#�#��U�[�[� � ��%�� � �3�u�:��?�y�E�7I��U�9�%�%�%� r �a�bc �J � U R S:X d UR S:X a gXL $ )z�Return True if two reducer operators should be considered equal.12 13Lambdas all share the name '<lambda>' so identity comparison is14unreliable; treat any pairing that includes a lambda as equal.15z<lambda>T)�__name__)r% r& s r �_operators_equalr) ( s% � � �z�z�Z� �1�:�:��#;�� �6�Mr c � ^ � \ rS rSrSrSrS\\ S\\\/\4 4U 4S jjr S\16S\ 4S jr \
S\\ 4S17 j5 r\
S\\ 4S j5 rS\4S jrS
\S\4S jrS\\ S\ 4S jrS\4S jrS\ 4S jrS\4S jrSrU =r$ )r �3 z�Stores the result of applying a binary operator to the current value and each new value.18 19```python20import operator21 22total = Channels.BinaryOperatorAggregate(int, operator.add)23```24)r �operator�typr, c �25 >� [ TU ] U5 X l [ U5 nU[ R26 R [ R27 R 4; a [ nU[ R28 R [ R29 R 4; a [ nU[ R30 R [ R31 R 4; a [ n U" 5 U l g ! [ a [" U l g f = f�N)�super�__init__r, r � collections�abcr �MutableSequence�list�Set�32MutableSet�set�Mapping�MutableMappingr! r � Exceptionr )�selfr- r, � __class__s �r r1 � BinaryOperatorAggregate.__init__? s� �� �
���� � �
� �C� �� �;�?�?�+�+�[�_�_�-L�-L�M� M��C� �;�?�?�&�&� ���(B�(B�C� C��C� �;�?�?�*�*�K�O�O�,J�,J�K� K��C� !� ��D�J��� !� �D�J� !�s � C* �*D�Dr r c �p � [ U[ 5 =( a [ U R UR 5 $ r/ )r r r) r, )r< r s r �__eq__� BinaryOperatorAggregate.__eq__P s, � ��%�!8�9� 33�>N� �M�M�5�>�>�?34� 35r c � � U R $ )z,The type of the value stored in the channel.�r- �r< s r � ValueType�!BinaryOperatorAggregate.ValueTypeU �
� � �x�x�r c � � U R $ )z/The type of the update received by the channel.rC rD s r �36UpdateType�"BinaryOperatorAggregate.UpdateTypeZ rG r c � � U R U R U R 5 nU R Ul U R Ul U$ )z Return a copy of the channel.)r= r- r, �keyr )r< �emptys r �copy� BinaryOperatorAggregate.copy_ s5 � ����t�x�x�� � �7���H�H�� ��j�j�� �� r �37checkpointc � � U R U R U R 5 nU R Ul U[ La Xl U$ r/ )r= r- r, rL r r )r< rP rM s r �from_checkpoint�'BinaryOperatorAggregate.from_checkpointf s7 � ����t�x�x�� � �7���H�H�� � �W� $�$�K�� r �valuesc �R � U( d gU R [ L a US U l USS nSnU Hu n[ U5 u pEU( a4 U( a# [ S[ R38 S9n[
U5 eXPl SnMK U( a MT U R U R U5 U l Mw g)NFr r z4Can receive only one Overwrite value per super-step.)�message�39error_codeT)r r r$ r r � INVALID_CONCURRENT_GRAPH_UPDATEr r, )r< rT �seen_overwriter � is_overwrite�overwrite_value�msgs r �update� BinaryOperatorAggregate.updatem s� � ��� �:�:�� � ���D�J��A�B�Z�F� $���E�,:�5�,A� )�L��!�.� V�#,�#L�#L��C� -�S�1�1� ,�40�!%���!�>� !�]�]�4�:�:�u� =��41� � r c �T � U R [ L a42 [ 5 eU R $ r/ )r r r rD s r �get�BinaryOperatorAggregate.get� s! � � �:�:�� �#�%� %��z�z�r c �& � U R [ L$ r/ )r r rD s r � is_available�$BinaryOperatorAggregate.is_available� s � ��z�z��(�(r c � � U R $ r/ r# rD s r rP �"BinaryOperatorAggregate.checkpoint� s � ��z�z�r )r, r )r( �43__module__� __qualname__�__firstlineno__�__doc__� __slots__�typer
r r1 �object�boolr@ �propertyrE rI r rN rR r r] r` rc rP �__static_attributes__�
__classcell__)r= s @r r r 3 s� �� �� &�I�!�D��K� !�8�U�E�N�E�<Q�3R� !�"44�F� 45�t� 46�47 ��4��;� � �� ��D��K� � ���d� ��%� �D� ��X�e�_� �� �.�U� �48)�d� )��E� � r r ) �collections.abcr2 r r �typingr r �typing_extensionsr r r � langgraph._internal._constantsr49 �langgraph._internal._typingr �langgraph.channels.baser r
�langgraph.errorsr r r r �langgraph.typesr �__all__r �tuplern r$ r) r � r r �<module>r} s� �� � .� � 9� 9� 4� /� 6�� � &�50&��
��#� �%��c� �"2� ��� �X� �$� �Z�g�e�n�k�%���:M�.N� Zr