<i SSKrSSKJrJr SSKJrJr SSKJrJ r J r SSK J r SSK Jr SSKJrJr SSKJrJrJrJr SS KJr S rS rS \S \\\44Sjr"SS\\\\\\45rg)N)CallableSequence)AnyGeneric) NotRequiredRequiredSelf) OVERWRITE)MISSING) BaseChannelValue)EmptyChannelError ErrorCodeInvalidUpdateErrorcreate_error_message) Overwrite)BinaryOperatorAggregatec[US5(a[UR5$[US5(a2UR[[4;a[UR S5$U$)z=Strips Annotated, Required and NotRequired from a given type. __origin__r)hasattr _strip_extrasrrr__args__)ts h/home/dmtnaga/Documents/work/airagagent/rag_env/lib/python3.13/site-packages/langgraph/channels/binop.pyrrsSq,Q\\**q,ALLX{4K$KQZZ]++ Hvaluereturnc[U[5(aSUR4$[U[5(a-[ UR 55[ 1:Xa SU[ 4$g)zEInspects the given value and returns (is_overwrite, overwrite_value).T)FN) isinstancerrdictsetkeysr rs r_get_overwriter$ sR%##U[[  %3uzz|#4 #CU9%%% rc^\rSrSrSrSrS\\S\\\/\44U4Sjjr S\ S\ 4S jr \ S\\4S j5r\ S\\4S j5rS\4S jrS \S\4SjrS\\S\ 4SjrS\4SjrS\ 4SjrS\4SjrSrU=r$)r)zStores the result of applying a binary operator to the current value and each new value. ```python import operator total = Channels.BinaryOperatorAggregate(int, operator.add) ``` )roperatortypr'c >[TU]U5 X l[U5nU[R R [R R4;a[nU[R R[R R4;a[nU[R R[R R4;a[nU"5Ulg![ a ["Ulgf=fN)super__init__r'r collectionsabcrMutableSequencelistSet MutableSetr!MappingMutableMappingr r Exceptionr )selfr(r' __class__s rr, BinaryOperatorAggregate.__init__5s  C  ;??++[__-L-LM MC ;??&& (B(BC CC ;??**KOO,J,JK KC !DJ ! DJ !s C**DDrrc[U[5=(aN URRS:wa2URRS:waURURL$S$)NzT)rrr'__name__)r6rs r__eq__BinaryOperatorAggregate.__eq__FsW%!89 ~~&&*4 &&*4 NNdmm +   rcUR$)z,The type of the value stored in the channel.r(r6s r ValueType!BinaryOperatorAggregate.ValueTypeN xxrcUR$)z/The type of the update received by the channel.r>r?s r UpdateType"BinaryOperatorAggregate.UpdateTypeSrBrcURURUR5nURUlURUlU$)zReturn a copy of the channel.)r7r(r'keyr)r6emptys rcopyBinaryOperatorAggregate.copyXs5txx7HH jj  r checkpointcURURUR5nURUlU[LaXlU$r*)r7r(r'rGr r)r6rKrHs rfrom_checkpoint'BinaryOperatorAggregate.from_checkpoint_s7txx7HH W $$K rvaluescRU(dgUR[LaUSUlUSSnSnUHun[U5upEU(a4U(a#[S[R S9n[ U5eXPlSnMKU(aMTURURU5UlMw g)NFrz4Can receive only one Overwrite value per super-step.)message error_codeT)rr r$rrINVALID_CONCURRENT_GRAPH_UPDATErr')r6rOseen_overwriter is_overwriteoverwrite_valuemsgs rupdateBinaryOperatorAggregate.updatefs :: DJABZF$E,:5,A )L!. V#,#L#LC-S11, !%!>!]]4::u= rcTUR[La [5eUR$r*)rr rr?s rgetBinaryOperatorAggregate.get}s! :: #% %zzrc&UR[L$r*)rr r?s r is_available$BinaryOperatorAggregate.is_availableszz((rcUR$r*r#r?s rrK"BinaryOperatorAggregate.checkpoints zzr)r'r)r: __module__ __qualname____firstlineno____doc__ __slots__typer rr,objectboolr;propertyr@rDr rIrMrrYr\r_rK__static_attributes__ __classcell__)r7s@rrr)s&I!DK!8UENErysr.994/6 & & #%c "2]genk%:M.N]r