9i;ddlmZddlmZmZddlmZddlmZm Z m Z ddl m Z ddl mZddlmZe dZe d Ze d Zd ZGd d e eeefeZy)) annotations)ABCabstractmethod)Sequence)AnyGenericTypeVar)Self)MISSING)EmptyChannelErrorValueUpdate Checkpoint) BaseChannelceZdZdZdZdddZeeddZeeddZ ddZ ddZ eddZ edd Z dd Zedd Zdd Zdd Zy)rzBase class for all channels.)keytypc ||_||_y)N)rr)selfrrs a/var/www/html/backtest/airagagent/rag_env/lib/python3.12/site-packages/langgraph/channels/base.py__init__zBaseChannel.__init__scy)z,The type of the value stored in the channel.Nrs r ValueTypezBaseChannel.ValueTypercy)z/The type of the update received by the channel.Nrrs r UpdateTypezBaseChannel.UpdateType!rrc@|j|jS)zReturn a copy of the channel. By default, delegates to `checkpoint()` and `from_checkpoint()`. Subclasses can override this method with a more efficient implementation. )from_checkpoint checkpointrs rcopyzBaseChannel.copy(s##DOO$566rcN |jS#t$r tcYSwxYw)zReturn a serializable representation of the channel's current state. Raises `EmptyChannelError` if the channel is empty (never updated yet), or doesn't support checkpoints. )getr r rs rr"zBaseChannel.checkpoint1s'  88:   N s $$cy)zReturn a new identical channel, optionally initialized from a checkpoint. If the checkpoint contains complex data structures, they should be copied. Nr)rr"s rr!zBaseChannel.from_checkpoint<rrcy)zyReturn the current value of the channel. Raises `EmptyChannelError` if the channel is empty (never updated yet).Nrrs rr%zBaseChannel.getErrcD |jy#t$rYywxYw)zReturn `True` if the channel is available (not empty), `False` otherwise. Subclasses should override this method to provide a more efficient implementation than calling `get()` and catching `EmptyChannelError`. TF)r%r rs r is_availablezBaseChannel.is_availableKs%   HHJ   s  cy)aUpdate the channel's value with the given sequence of updates. The order of the updates in the sequence is arbitrary. This method is called by Pregel for all channels at the end of each step. If there are no updates, it is called with an empty sequence. Raises `InvalidUpdateError` if the sequence of updates is invalid. Returns `True` if the channel was updated, `False` otherwise.Nr)rvaluess rupdatezBaseChannel.updateYrrcy)aNotify the channel that a subscribed task ran. By default, no-op. A channel can use this method to modify its state, preventing the value from being consumed again. Returns `True` if the channel was updated, `False` otherwise. Frrs rconsumezBaseChannel.consumeercy)zNotify the channel that the Pregel run is finishing. By default, no-op. A channel can use this method to modify its state, preventing finish. Returns `True` if the channel was updated, `False` otherwise. Frrs rfinishzBaseChannel.finishpr/rN))rrrstrreturnNone)r4r)r4r )r4Checkpoint | Any)r"r6r4r )r4r )r4bool)r+zSequence[Update]r4r7)__name__ __module__ __qualname____doc__ __slots__rpropertyrrrr#r"r!r%r)r,r.r1rrrrrs&I;;>> 7   SS  I I  rrN) __future__rabcrrcollections.abcrtypingrrr typing_extensionsr langgraph._internal._typingr langgraph.errorsr r rr__all__rrrrrFs\"#$(("/.   \ " f'%34cfr