(GgG ddlmZmZddlmZmZmZmZddlm Z ddl m Z ddl m Z mZedZedZedZGd d eeeefeZgd Zy ) )ABCabstractmethod)AnyGenericSequenceTypeVar)Self)MISSING)EmptyChannelErrorInvalidUpdateErrorValueUpdateCceZdZdZddededdfdZeedefdZ eedefdZ de fd Z de fd Zed e de fd Zed eedefdZedefdZdefdZdefdZy) BaseChannel)keytyprrreturnNc ||_||_y)N)rr)selfrrs t/home/kushmeetdev/apache_webroot/langgraph_flaskproject/venv/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.UpdateTyperrc@|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.checkpoint's' 88:   N s $$r#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_checkpoint0rrvaluescy)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)rr(s rupdatezBaseChannel.update7rrcy)zwReturn the current value of the channel. Raises EmptyChannelError if the channel is empty (never updated yet).Nrrs rr&zBaseChannel.get@rrcy)zMark the current value of the channel as consumed. By default, no-op. This is called by Pregel before the start of the next step, for all channels that triggered a node. If the channel was updated, return True. Frrs rconsumezBaseChannel.consumeFs rcD |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_availableMs%   HHJ   s  ))__name__ __module__ __qualname__ __slots__rstrrpropertyrrr r r$rr#r"rrboolr*r r&r-r/rrrrrsICc4;3;;>C>> 7d7 AV!VVV EXf-E$EEQUQQ  d rr)rr r N)abcrrtypingrrrrtyping_extensionsr langgraph.constantsr langgraph.errorsr r r rrr__all__rrrr>sX#22"'B   CLH'%*+SHV r