codekingpro/portable-devtools
114k
1�
2 ��j� � �� � S SK Jr S SKrS SKrS SKJrJr S SKJ r J3r4 S SK J r S SK
Jr S SKJr S SKJr S S KJrJr S S5KJrJrJr S S KJrJ r J r J r S r " S
S\6\ \\ \ \ 4 5 r g)� )� annotationsN)�Callable�Sequence)�Any�Generic)� PendingWrite)�_DeltaSnapshot)�Self��MISSING)� BaseChannel�Value)�_get_overwrite�_operators_equal�
_strip_extras)�EmptyChannelError� ErrorCode�InvalidUpdateError�create_error_message)� DeltaChannelc �� ^ � \ rS rSr% SrSrS\S' SSS. SU 4S jjjjrSS jr\ SS7 j5 r8\ SS j5 r SS jr SS
jr
SS jrSS jrSS jrS S jrSS jrSrU =r$ ) r � ag Reducer channel that stores only a sentinel in checkpoint blobs and9reconstructs state by replaying ancestor writes through the reducer.10 11!!! warning "Beta"12 13 `DeltaChannel` is in beta. The API and on-disk representation may14 change in future releases. Threads written with `DeltaChannel` today15 are expected to remain readable, but the surrounding contract16 (`BaseCheckpointSaver.get_delta_channel_history`, the17 `_DeltaSnapshot` blob shape, the `counters_since_delta_snapshot`18 metadata field) is not yet stable.19 20The reducer receives the current accumulated value and a batch of writes21in one call: `reducer(state, [write1, write2, ...]) -> new_state`.22 23Reducers must be deterministic and batching-invariant (associative across24folds): applying two consecutive write batches separately must produce the25same state as applying their concatenation once:26 27 reducer(reducer(state, xs), ys) == reducer(state, xs + ys)28 29This lets LangGraph replay checkpointed writes in larger batches than they30were originally produced without changing reconstructed state.31 32Snapshot cadence is driven by two counters: per-channel update count and33total supersteps since last snapshot. `create_checkpoint` writes a full34`_DeltaSnapshot` blob when EITHER the update count reaches35`snapshot_frequency` OR the supersteps count reaches the system-wide36`DELTA_MAX_SUPERSTEPS_SINCE_SNAPSHOT` bound (default 5000), bounding37replay depth even for channels that stop receiving writes.38 39Parameters:40 reducer: `(state, list[writes]) -> new_state`. Must be deterministic41 and batching-invariant as described above.42 typ: The value type (e.g. `list`, `dict`). Inferred automatically43 from the outer type when used inside `Annotated[T, DeltaChannel(...)]`.44 snapshot_frequency: Every Nth update to this channel writes a snapshot45 blob (default `1000`). Must be a positive int.46)�value�reducer�snapshot_frequencyz Value | Anyr i� �r c �" >� US:: a [ SU 35 eUc [ n[ TU ]
U5 Xl X0l [
U5 nU[ R R [ R R 4; a [ nU[ R R [ R R 4; a [ nU[ R R [ R R 4; a [ nX l [$ U l g )Nr z/snapshot_frequency must be a positive int, got )�47ValueError�list�super�__init__r r r � collections�abcr �MutableSequence�Set�48MutableSet�set�Mapping�MutableMapping�dict�typr r )�selfr r+ r � __class__s ��^D:\code\apps\devtools\python\user_packages\Python313\site-packages\langgraph/channels/delta.pyr! �DeltaChannel.__init__E s� �� � �� "� �A�BT�AU�V��
� �;��C�
���� � � �"4� ��C� �� �;�?�?�+�+�[�_�_�-L�-L�M� M��C� �;�?�?�&�&� ���(B�(B�C� C��C� �;�?�?�*�*�K�O�O�,J�,J�K� K��C���!��49� c � � [ U[ 5 ( d gU R UR :w a g[ U R UR 5 $ )NF)�50isinstancer r r r )r, �others r. �__eq__�DeltaChannel.__eq___ s> � ��%� �.�.�� � "� "�e�&>�&>� >�� �� � �e�m�m�<�<r0 c � � U R $ �N�r+ �r, s r. � ValueType�DeltaChannel.ValueTypef � � ��x�x�r0 c � � U R $ r7 r8 r9 s r. �51UpdateType�DeltaChannel.UpdateTypej r< r0 c � � U R U R U R U R S9nU R Ul U R52 [ L a U R53 Ul U$ [ R " U R54 5 Ul U$ )Nr ) r- r r+ r �keyr r �_copy�copy)r, �news r. rC �DeltaChannel.copyn sn � ��n�n� �L�L�$�(�(�t�7N�7N� � 55�� �(�(���"&�*�*��"7�D�J�J�� ��56� >C�Z�Z��57�58�=S�� ��59r0 c �" � U R U R U R U R S9nU R Ul U[60 L a U R 5 Ul U$ [ U[ 5 ( a UR Ul U$ Xl U$ )z�Initialize from a stored blob.61 62Blob types:63 * `MISSING`: start empty; caller replays writes.64 * `_DeltaSnapshot(value)`: restore value directly from snapshot.65 * plain value (migration from old `BinaryOperatorAggregate` blobs):66 use directly.67r ) r- r r+ r rA r r r2 r )r, �68checkpointrD s r. �from_checkpoint� DeltaChannel.from_checkpointv s� � � �n�n� �L�L�$�(�(�t�7N�7N� � 69�� �(�(��� �� � ���70�C�I�71 �72� �73�N�
3�
3�"�(�(�C�I� �74� #�I��75r0 c �l � U VVs/ s H u p#UPM76 nnnU( d gU R nSn[ U5 HI u ps[ U5 u p�U( d M U b [ R " U 5 OU R 5 nUS- nMK XFS n77U78( a U R
XZ5 U l gUU l gs snnf )z�Apply ancestor writes oldest-to-newest via a single reducer call.79 80If any write is an Overwrite, the last one in the sequence acts as81the reset point: its value becomes the new base and only writes82after it are passed to the reducer.83Nr � )r � enumerater rB rC r+ r ) r, �writes�_�v�values�base�start�i�is_ow�ow_value� remainings r. �
replay_writes�DeltaChannel.replay_writes� s� � � $*�*�6���1�!�6��*�� ��z�z���� �f�%�D�A� ,�Q� /�O�E��u�/7�/C�u�z�z�(�+�������A��� &�84 �6�N� �6?�T�\�\�$�2��85�T��86�� +s �B0c �h � U( d gS n[ U5 HC u p4[ U5 u pVU( d M Ub# [ S[ R S9n[ U5 eUnME Ub~ [ X 5 u phUb [ R " U5 OU R 5 n [ U5 VVs/ s H u p4X2:w d M UPM n87nnU88( a U R X�5 OU U l89 gU R [ L a U R 5 O U R n U R U [ U5 5 U l90 gs snnf )NFz4Can receive only one Overwrite value per super-step.)�message�91error_codeT)
rL r r r � INVALID_CONCURRENT_GRAPH_UPDATEr rB rC r+ r r r r ) r, rP �
overwrite_idxrS rO rT rN �msg�overwrite_valuerQ rV s r. �update�DeltaChannel.update� s � ���$(�
� �f�%�D�A�%�a�(�H�E��u� �,�.� V�#,�#L�#L��C� -�S�1�1� !�
� &� � $�!/��0E�!F� �A� #�.� �92�93�?�+��X�X�Z�
�94 (1��'8�O�'8�t�q�A�<N��'8�I�O�:C�� � �d�6��D�J�� !�Z�Z�7� 2�t�x�x�z��95�96���\�\�$��V� �5��97��� Ps �& D.�5D.c �T � U R [ L a98 [ 5 eU R $ r7 )r r r r9 s r. �get�DeltaChannel.get� s! � � �:�:�� �#�%� %��z�z�r0 c �& � U R [ L$ r7 )r r r9 s r. � is_available�DeltaChannel.is_available� s � ��z�z��(�(r0 c � � [ $ )a_ Return stored representation: always `MISSING`.99 100Snapshot decisions live in `create_checkpoint` (which has the channel101version) and write `_DeltaSnapshot(ch.get())` directly into102`channel_values`. For non-snapshot steps the channel does not appear103in `channel_values`; reconstruction walks ancestor writes via the104saver's `get_delta_channel_history`.105r r9 s r. rG �DeltaChannel.checkpoint� s � � �r0 )r r r+ r r7 )r z#Callable[[Any, Sequence[Any]], Any]r+ ztype[Value] | Noner �int�return�None)r3 �objectrk �bool)rk r )rk r106 )rG r rk r107 )rM zSequence[PendingWrite]rk rl )rP z
Sequence[Any]rk rn )rk rn )�__name__�108__module__� __qualname__�__firstlineno__�__doc__� __slots__�__annotations__r! r4 �propertyr: r> rC rH rW r` rc rf rG �__static_attributes__�
__classcell__)r- s @r. r r s� �� �&�P ;�I� ��109 #'�"�110 #'� "�4�"� �"�111 � "� 112�
"� "�4=� �� �� �� ����*J�(�8�113)� � r0 r )!�114__future__r �collections.abcr" rC rB r r �typingr r �langgraph.checkpoint.baser � langgraph.checkpoint.serde.typesr �typing_extensionsr115 �langgraph._internal._typingr �langgraph.channels.baser
r �langgraph.channels.binopr r r �langgraph.errorsr r r r �__all__r � r0 r. �<module>r� sY �� "� � � .� � 2� ;� "� /� 6� T� T�� � ��s�7�5�>�;�s�C��}�#=� sr0